[Bug] job cannot track the checkpoint path

[xinzhuxiansheng]

Search before asking

• I had searched in the issues and found no similar issues.

Java Version

1.8

Scala Version

2.12.x

StreamPark Version

2.1.5

Flink Version

Flink 1.16.2

Deploy mode

kubernetes-application

What happened

When the job is configured with the UNALIGNED_CHECKPOINT parameter, the latest checkpoint is obtained through the REST API. Its corresponding checkpoint type is UNALIGNED_CHECKPOINT, which does not match the enumeration value in the code, causing the job to be unable to track the checkpoint path.

当 job 配置 UNALIGNED_CHECKPOINT 参数，那通过 REST API 获取 checkpoint 的 latest ，它对应的 checkpoint type 是 UNALIGNED_CHECKPOINT，并不能与 代码中的枚举值匹配，造成 job 无法跟踪 checkpoint 路径

Error Exception

Screenshots

Are you willing to submit PR?

• Yes I am willing to submit a PR!(您是否要贡献这个PR?)

Code of Conduct

• I agree to follow this project's Code of Conduct