流计算

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

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

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

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

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

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

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

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

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

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

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

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