实时计算 Flink版

Flink cdc 3.0是不是不支持增量？ 以下为热心网友提供的参考意见 Flink CDC 3.0 确实支持增量功能。Flink CDC 是基于数据库日志 CDC（Change…

flink 1.18启动sql client异常 ，有人知道为什么吗？ 以下为热心网友提供的参考意见 我是加个sudo就好了 或者环境变量没配置好 或者多个版本环境变量配置冲突 ，…

有人接过influxDB吗？Flink这里为什么没有提供setHost()？ 以下为热心网友提供的参考意见 在Flink中使用InfluxDB时，需要先配置InfluxDB的连接信…

flink1.14的网络缓存消胀机制，如果只是逻辑减少buffer的大小，并物理的大小不变，这是不是会导致内存浪费?它是会改变所有的subtask的buffer大小吗？还是只有某个…

请教一下，flink on yarn模式下，怎么对job作业进行指标监控？job整理时延，吞吐量等性能指标想拿jmx看 以下为热心网友提供的参考意见 在Flink on Yarn模…

Flink有人遇到这个问题不？ 以下为热心网友提供的参考意见 这个问题可能是由于Kafka Connect在处理字段名时出现了问题。请检查您的Kafka Connect配置文件中的…

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

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

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

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

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

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