匿名

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

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

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

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

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

提交flink任务一直刷这个信息是什么情况？资源是充足的 以下为热心网友提供的参考意见 根据你提供的日志，看起来你的 Flink 作业在部署时超出了60秒的限制。这可能意味着资源不…

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

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

Flink自定义的Source实现了RichParallelSourceFunction，并行时ctx.collect会阻塞，不报错，但一直不往下执行，请教下，有没有排查或者解决问…

Flink给每张mysql的表都配置了一个server-id的范围，提交多个任务时，还是有一些任务失败，报错如图。请问这种问题怎么排查？ 以下为热心网友提供的参考意见 要排查Fli…

Flink中kafka 的精准一次 sink 如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了 我这批数据会丢失吗？ 以下为热心网友提供的参考意见 如果你配置了最大连续…

Flink中间计算结果如果存到redis， 合适吗 前辈们， checkpoint 咋保证一致性呢 ？ 以下为热心网友提供的参考意见 将Flink的中间计算结果存储到Redis中是…