实时计算 Flink版

Flink的元数据血缘的获取 大家有什么方案吗？ 以下为热心网友提供的参考意见 Flink的元数据血缘可以通过以下方案获取： 使用Flink的内置表API或SQL API进行查询，…

Flink1.14.4版本消费kafka数据，能外部保存偏移量并维护吗？ 以下为热心网友提供的参考意见 是的，Flink 1.14.4版本支持外部保存Kafka消费偏移量并维护。 …

在flink实时任务中，POJO对象模式演进已经发生不兼容的时候，有什么办法可以处理？ 以下为热心网友提供的参考意见 在Flink实时任务中，当POJO对象模式演进发生不兼容时，处…

Flink1.17.2版本只有2.12的Scala的安装包吗？有没有链接直达2.11的 以下为热心网友提供的参考意见 Flink 1.17.2版本主要支持Scala 2.12，没有…

Flink报错怎么解决？flink on yarn 模式 跑wordcount run ./examples/batch/WordCount.jar –input hd…

Flink中在文件后面加回车换行了，还是提示这个错误，怎么回事？ 以下为热心网友提供的参考意见 这个错误提示是因为Flink在处理文件时，期望文件以空行结尾。即使您已经在文件末尾添…

Flink的docker镜像的 pod里的java路径和 container里的java路径不一样，这个咋搞的？ 以下为热心网友提供的参考意见 Flink的docker镜像中jav…

Flink1.10 kafka0.10运行一段时间后，我把kafka停了，但是flink没有失败，一直在报broker可能不存在的警告，怎么解决呢？我没有配置重启策略，我希望任务在…

flink-connector-jdbc 1.18 计划什么时候发布啊？

Flink本地运行这个错是什么原因？ 以下为热心网友提供的参考意见 此回答整理自钉群“【①群】Apache Flink China社区”

Flink中invoke之前 判断当前链接是否有效 无效就重连 我们也遇到这种情况了？ 以下为热心网友提供的参考意见 在Flink中，如果需要判断当前链接是否有效并在无效时重连，可…

Flink使用richsinkfunction，写入PG，每隔半小时就报错和PG断开连接（数据发送间隔时间很长，导致长时间会没有数据），该怎么解决啊？我用了druid连接池，配置了…