匿名

请教个问题，我在83服务器上部署了一个Flink1.17 ，然后我有两个mysql数据库，分别部署在63服务器和81服务上了，我在往83提交cdc作业时（链接的是81服务器上的数据…

我在使用flink kafka连接器的时候，遇到报错问题，没有分析思路，请各位大佬指教一下报错如下图：kafka集成了kerberos，flink是 on yarn模式，与kafk…

有什么办法让flink在windows运行，单机都行? 以下为热心网友提供的参考意见 首先，您需要从Flink官网或者Apache的存档站点下载Flink安装包。以Flink 1.…

大家有遇到Flink这问题吗?在1.15.4里报错。Caused by: java.util.concurrent.CompletionException: org.apache.…

想问下Flink sql作业支持写判断语句吗，根据标志执行删除，或是更新或是插入? 以下为热心网友提供的参考意见 是的，Flink SQL支持写判断语句。您可以使用CASE WHE…

请问一下，flink sql udf 通过字符串这样传进来，然后用groovy编译成Class，然后通过tableEnv去注册，这样会报错。大家有没有一个好的实现办法呀？外面传个字…

有Flink 的SqlServer 2000版本的驱动包吗？ 以下为热心网友提供的参考意见 Flink支持与多种数据库的连接，但对于SqlServer 2000版本的驱动包，目前公…

想问下我这边Flink在keyby之后数据还是有的，但是到后面的流程里数据就没有了，这是什么原因？ 以下为热心网友提供的参考意见 楼主你好，看了你的描述，需要你检查keyBy操作是…

这个指标该怎么在flink ui上获取呢？我想看端到端的延迟统计 找了一圈没找到这个api该怎么传参？ 以下为热心网友提供的参考意见 在Flink UI上获取IO指标，可以通过以下…

有没有 大佬用 springboot 启动flink 处理 ，发现springboot 加 schedule调度处理会内存占满情况？ 以下为热心网友提供的参考意见 在Spring …

有没部署过flink sql gateway的呀？一直报错 org.apache.thrift.protocol.TProtocolException: Missing versi…

Flink1.18.0 拿rancher k8s部署 taskmanager报连不上taskmanager 然后一直重启，大家有见过这种情况吗？ 以下为热心网友提供的参考意见 是的…