[Bug] application start without savepoint, the savepoint in job info detail won't updated #4074
Open
3 tasks done
Labels
bug
Something isn't working
Search before asking
Java Version
jdk8
Scala Version
2.12.x
StreamPark Version
2.1.4
Flink Version
1.15.0
deploy mode
kubernetes-application
What happened
application start without savepoint, the savepoint in job info detail won't updated(我将一个作业启动时不勾选从sp/cp启动后,作业是正常运行的,但是在作业的详情页里的savepoint里,ck不再更新了还是以前的,数据库里也看了,确实没更新)
Error Exception
Screenshots
I suspect this is due to a method in this class that compares only the chkid completion time, not the chk completion time. After the job restarts without sp/cp, the checkpoint id starts from 1
(我怀疑是这个类的这个方法导致的,这个方法里只比较了chkid,而不是chk的完成时间,在作业无sp/cp重启后,checkpoint的id又是从1开始的)
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: