实时计算 Flink版

Flink中kafkaSink 使用精准一次性语意 为啥恢复任务的时候初始化的时间很长 会导致 ck 失败？ 以下为热心网友提供的参考意见 Flink中kafkaSink使用精准一…

Flink在算子里之后要怎么处理啊，调用第三方json解析包去解析json吗？ 以下为热心网友提供的参考意见 Flink在算子里可以使用第三方JSON解析包来解析JSON数据。常见…

Flink中executeplain和statementset怎么结合？ 以下为热心网友提供的参考意见 在Flink中，executeplain和statementset可以一起使…

Flink在第一个Sink失败的情况下 导致 在switch source算子运行状态 从running变成 cancelling 失败报错 是因为 ResultSet.close…

streamAPI闯天下，用什么flinkSQL？flinkSQL也要转换成stream运行，SQL是建立在stream之上的 以下为热心网友提供的参考意见 Flink SQL 是…

Flink为什么不生效啊？未提交的数据仍然能被消费到kafkaSource 配置了isolation.level=read_committed 以下为热心网友提供的参考意见 Fli…

Flink是不能直接用 sql api, 要用stream api map 取出来再用sql api 做进步的处理吗？ 以下为热心网友提供的参考意见 Apache Flink确实支…

flinksql 新增字段后状态失效，无法使用savepoint启动 有什么解决方案吗？ 以下为热心网友提供的参考意见 当使用Flink SQL新增字段后，如果状态失效，无法使用s…

flink1.18 Yarn Application 提交，有人遇见过？ 以下为热心网友提供的参考意见 这个问题可能是由于Flink在提交Yarn Application时，无法找…

Flink数据源是 mysql 和官网上的一样的？ 以下为热心网友提供的参考意见 第一，你去重写序列化类，第二在算子中处理 ，此回答整理自钉群“【③群】Apache Flink C…

Flink中keyed state can only be used on a ‘keyed stream’不keyby()的流, 怎么存储状态呢？ 以下为…

flink的jobmanager内存总是持续升高直到宕机，这个是什么原因呀，有解决思路么？应该是失败重启导致的使用了restart策略，但是内存一直升高这个问题不知道怎么样解决 以…