[improvement] improvement flink cluster status update - Githubissues

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.

https://streampark.apache.org/

Apache License 2.0

3.91k stars 1.01k forks source link

[improvement] improvement flink cluster status update #2851

Closed xujiangfeng001 closed 1 year ago

xujiangfeng001 commented 1 year ago

Search before asking

[X] I had searched in the feature and found no similar feature requirement.

Description

Based on this pr https://github.com/apache/incubator-streampark/issues/2498. In order to better adapt to yarn state, the Flink cluster is optimized here as follows:

yarn session:

Yarn Session-Flink Cluster 状态梳理

remote:

Remote-Flink Cluster 状态梳理

Usage Scenario

Optimize flink cluster state update.

Related issues

No response

Are you willing to submit a PR?

[X] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

wolfboys commented 1 year ago

good job, looking forward to this PR.