Re: Flink状态调试
抱歉,我似乎回错邮件了,应该使用回复全部? Congxian Qiu 于2020年7月6日周一 下午7:22写道: > Hi > 想 debug checkpoint 文件的话,可以参考下这个 UT[1] > > [1] > > https://github.com/apache/flink/blob/master/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java > Best, > Congxian > > > Z-Z 于2020年7月6日周一 下午4:59写道: > > > Hi, 各位大佬们,请教一下: > > Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗? >
Re: Flink状态调试
Hi Z-Z, 如果你想查看的是程序中的state内容,建议触发一次savepoint并搭配state processor api来查询。 参考 https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/libs/state_processor_api.html Best, shizk233 Congxian Qiu 于2020年7月6日周一 下午7:22写道: > Hi > 想 debug checkpoint 文件的话,可以参考下这个 UT[1] > > [1] > > https://github.com/apache/flink/blob/master/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java > Best, > Congxian > > > Z-Z 于2020年7月6日周一 下午4:59写道: > > > Hi, 各位大佬们,请教一下: > > Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗? >
Re: Flink状态调试
Hi 想 debug checkpoint 文件的话,可以参考下这个 UT[1] [1] https://github.com/apache/flink/blob/master/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java Best, Congxian Z-Z 于2020年7月6日周一 下午4:59写道: > Hi, 各位大佬们,请教一下: > Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗?