flink yarn-per-job???? ynm????????????

[Lawulu]

??
bin/flink run -ynm flink-test -t yarn-per-job --detached 
./examples/streaming/TopSpeedWindowing.jar


??yarn ui??nameFlink per-job cluster

??????????

[JasonLee]

Hi


?? user-zh-unsubscr...@flink.apache.org 


Best
JasonLee


??2021??10??25?? 10:52??zdj<1361776...@qq.com.INVALID> ??

????

[zdj]

Re: 在开启checkpoint后如何设置offset的自动提交以方便监控

[Caizhi Weng]

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后如何设置offset的自动提交以方便监控

[杨浩]

请问下，如果启用checkpoint，因为状态比较大，checkpoint间隔设置比较大，如何让offset提交的比较快，这样方便监控程序进度