Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug] application start without savepoint, the savepoint in job info detail won't updated #4074

Open
3 tasks done
wjcwin opened this issue Sep 20, 2024 · 1 comment
Open
3 tasks done
Labels
bug Something isn't working

Comments

@wjcwin
Copy link
Contributor

wjcwin commented Sep 20, 2024

Search before asking

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

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

No details are displayed in logs

Screenshots

image
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?

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

Code of Conduct

@wjcwin wjcwin added the bug Something isn't working label Sep 20, 2024
@wjcwin
Copy link
Contributor Author

wjcwin commented Sep 20, 2024

this function maybe return not the flink job latestCheckpointId,is application history jobs latestCheckpointId
(这个方法对应新的作业的jobid而言是没有缓存ck的,所以会返回这个application在数据库中存储的最新的checkpointId,但是这个是之前历史job的,不应该与当前job的checkpoint进行比较了)
image

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

1 participant