Open
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
FlinkTrackController's trackIds, canceling, endpoints, jobStatuses uniformly use appId as Key.
trackIds,canceling use appId as key
jobStatuses use TrackId as key
StreamPark Version
1.2.4-SNAPSHOT
Java Version
No response
Flink Version
1.14.5
Scala Version of Flink
2.12
Error Exception
Only one job is run, and the size of the jobStatuses cache is 2
To explain its impact, `FlinkJobStatusWatcher.touchApplicationJob()` When jobDetails.isEmpty || jobDetails.get.jobs.isEmpty condition is true, inferApplicationFlinkJobStateFromK8sEvent() will change from
`val latest: JobStatusCV = trackController.jobStatuses.get(trackId)`
...
Screenshots
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct
Activity
wolfboys commentedon Sep 23, 2022
Thanks for your feedback, really a bug. welcome to fix it.