checkpoint保存的目录名问题

来源：16-8 重启策略测试

kingdomad

2020-10-20

每次任务的checkpoint都保存在类似

/flinkstate/1ae3c3b448d6765e5e0a1262aa418bcd
/flinkstate/bd0e51ee84f86b29eb3985dadea9ea94
/flinkstate/76597fbf4cf5506a1ff1286fdbf19eda

，这样的随机id的文件夹。
运行的flink任务多了之后就无法直观地从文件名去知道checkpoint文件夹和任务的对应关系。
请问下这个id可以自定义吗？
checkpoint文件夹要如何区分是哪个任务的？

写回答

1回答

Michael_PK

2020-10-20

chk的目录规则你可以通过UI查看到，一长串好像是jobid，然后每次chk之后会有一个1，2。。。的一个目录，然后具体的keyedstate或者operatorstate是记录在具体数字下的

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

相似问题

回答 2

回答 1

回答 1

回答 1

回答 1