You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I had searched in the issues and found no similar issues.
Java Version
1.8.0_345
Scala Version
2.12.x
StreamPark Version
2.1.5
Flink Version
Flink-1.16.2
deploy mode
yarn-application
What happened
This issue is similar to #1633 .
I learned from the debug source code that when I got the data of Flink Overview, the data was not accurate because Flink had just started, and the data obtained by debug was shown in the following figure.
I want to submit this PR, the idea is to delete the first judgment, because I think these information need to be obtained in real time, for example, the end time of different TM may be different, if this judgment is deleted, STARTING_CACHE will be deleted at the same time, because this cache is not referenced elsewhere, may I ask if this cache still needs to be retained?
Search before asking
Java Version
1.8.0_345
Scala Version
2.12.x
StreamPark Version
2.1.5
Flink Version
Flink-1.16.2
deploy mode
yarn-application
What happened
This issue is similar to #1633 .
I learned from the debug source code that when I got the data of Flink Overview, the data was not accurate because Flink had just started, and the data obtained by debug was shown in the following figure.
Error Exception
No response
Screenshots
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: