[Bug] Flink cluster status cannot be updated

[xujiangfeng001]

Search before asking

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

What happened

When I open a yarn session cluster, if the container fails in yarn for some reason, StreamPark cannot perceive the change of the yarn session.

StreamPark Version

1.2.4-SNAPSHOT

Java Version

1.8

Flink Version

1.14.4

Scala Version of Flink

2.12

Error Exception

no

Screenshots

No response

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

[xujiangfeng001]

@wolfboys Hello, I think it is necessary to monitor the Flink cluster. I don't know what your opinion is?

[RocMarshal]

@xujiangfeng001 Thanks for the driving this.
good proposal👍, and I'd like to make it pluggable, because the pluggable mechanism give the space to users for selection.
Please let's know what's your opinions. Thanks a lot.
CC @wolfboys

[RocMarshal]

hello, @xujiangfeng001 Would you like to support the feature? thx~

[xujiangfeng001]

@xujiangfeng001 Thanks for the driving this. good proposal👍, and I'd like to make it pluggable, because the pluggable mechanism give the space to users for selection. Please let's know what's your opinions. Thanks a lot. CC @wolfboys

Sorry, I don't quite understand what needs to be done. Can you elaborate?

[xujiangfeng001]

hello, @xujiangfeng001 Would you like to support the feature? thx~

Hello, this function is in my plan. I will improve this function as soon as possible.

[RocMarshal]

The issue migrated into #2425