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.82k stars 983 forks source link

[Bug] Flink restapi watching threads accumulate and blocked #3285

Open SusubingYi opened 9 months ago

SusubingYi commented 9 months ago

Search before asking

Java Version

1.8

Scala Version

2.12.x

StreamPark Version

2.1.1

Flink Version

1.14

deploy mode

yarn-application

What happened

The large amount of waiting threads in the Flink REST API watching executor leads to the accumulation of waiting, causing the failure of the streaming application state monitoring.

Error Exception

No response

Screenshots

企业微信截图_16982000305375

Are you willing to submit PR?

Code of Conduct

conorzhao commented 6 months ago

We maintained around 700 jobs and frequently encountered thread blocking issues. Only by restarting the service can we recover.