shangeyao opened a new issue, #4386: URL: https://github.com/apache/streampark/issues/4386
## Problem `FlinkAppHttpWatcher` and `SparkAppHttpWatcher` schedule polling every 1 second and submit a new executor task for each app on every tick, even when the previous poll has not finished. This causes redundant REST calls and thread pool pressure. ## Proposed solution - Track in-flight watch tasks per application with `AtomicBoolean` single-flight guard - Skip scheduling when a watch is already running - Clean up in-flight markers when an app is removed from the watch list -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
