实时计算 Flink版

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

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

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

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

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

flink有没得重启flink 的时候提交的任务也一起重启了，现在是里面有好几个人任务，停电服务器停止了，然后自动启动flink,但是提交的任务每的了？ 以下为热心网友提供的参考意…

flink 1.15.4 /tmp目录，看每天都会生成10多个flink-table-planner_xxx.jar，这个是什么情况呢？ 以下为热心网友提供的参考意见 这个现象可能…

flinksql的模式同步数据到doris？ 以下为热心网友提供的参考意见 要将Flink SQL的模式同步数据到Doris，可以按照以下步骤进行操作： 首先，确保你已经在Flin…

spark和flink sql取hash的函数是什么啊？需要取完的值是一样的，这个自带的函数有吗，哪位大佬知道啊？ 以下为热心网友提供的参考意见 在Spark和Flink SQL中…

flink sink websocket 需要哪个依赖？ 以下为热心网友提供的参考意见 要在Flink中使用WebSocket Sink，你需要依赖flink-streaming-…

Flink在 https://mvnrepository.com/ 上没有搜到， 有测试过 sink 到 websocket 的吗？ 以下为热心网友提供的参考意见 是的，Flink…

Flink中kafka总共有16266条数据, 但是消费到6144就停止并报这两条日志了？ 以下为热心网友提供的参考意见 从你给出的日志来看，问题是关于Kafka消费者未能获取足够…