??
bin/flink run -ynm flink-test -t yarn-per-job --detached
./examples/streaming/TopSpeedWindowing.jar
??yarn ui??nameFlink per-job cluster
Hi
?? user-zh-unsubscr...@flink.apache.org
Best
JasonLee
??2021??10??25?? 10:52??zdj<1361776...@qq.com.INVALID> ??
Hi!
这里的 offset 是 kafka source 的 offset 吗?其实没必要通过 checkpoint 读取 offset,可以通过
metrics 读取,见 [1]。
[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/metrics/#kafka-connectors
杨浩 于2021年10月25日周一 上午10:20写道:
> 请问下,如果启用checkpoint,因为状态比较大,checkpoint间隔设置比较大,如何让offset提交的比较快,这样方便监控程序进度
请问下,如果启用checkpoint,因为状态比较大,checkpoint间隔设置比较大,如何让offset提交的比较快,这样方便监控程序进度