Flink状态调试

classic Classic list List threaded Threaded
4 messages Options
Z-Z
Reply | Threaded
Open this post in threaded view
|

Flink状态调试

Z-Z
Hi, 各位大佬们,请教一下: Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗?
Reply | Threaded
Open this post in threaded view
|

Re: Flink状态调试

Congxian Qiu
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 <[hidden email]> 于2020年7月6日周一 下午4:59写道:

> Hi, 各位大佬们,请教一下:
> Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗?
Reply | Threaded
Open this post in threaded view
|

Re: Flink状态调试

shizk233
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 <[hidden email]> 于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 <[hidden email]> 于2020年7月6日周一 下午4:59写道:
>
> > Hi, 各位大佬们,请教一下:
> > Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗?
>
Reply | Threaded
Open this post in threaded view
|

Re: Flink状态调试

shizk233
In reply to this post by Congxian Qiu
抱歉,我似乎回错邮件了,应该使用回复全部?

Congxian Qiu <[hidden email]> 于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 <[hidden email]> 于2020年7月6日周一 下午4:59写道:
>
> > Hi, 各位大佬们,请教一下:
> > Flink的checkpoint怎么调试啊,我想看程序目前的状态,拿到了checkpoint的文件,打开后有一些东西是乱码,没有结构性,有方法吗?
>