Skip to content

Conversation

@Li-GL
Copy link

@Li-GL Li-GL commented Jan 20, 2026

What changes were proposed in this pull request

Issue Number: close #4301

Since the status of all applications is checked every 5 seconds, if the check cannot be completed within 5 seconds, it will cause the thread pool queue to accumulate. As a result, there may be multiple duplicate applications waiting in the thread pool queue, such as the same failed task that needs to be restarted appearing multiple times. This can lead to repeated application restarts and duplicate alerts.

Therefore, a WATCHING_IN_PROGRESS set is added here. If an application is already being watched, it will be skipped to ensure that there are no duplicate tasks in the thread pool queue.
image

Brief change log

fix duplicate application submissions and alerts when thread pool queue accumulates and failed task needs to be restarted

Verifying this change

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

Does this pull request potentially affect one of the following parts

  • Dependencies (does it add or upgrade a dependency): (yes / no)

@sonarqubecloud
Copy link

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Bug] flink任务在异常过程中,从streampark重启该任务的情况,会导致任务重复。

1 participant