[Bug] [Flink] stop flink job error · apache/dolphinscheduler#16789

2024-11-11T07:23:33.000Z

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/dolphinscheduler/issues?q=is%3Aissue) and found no similar issues. ### What happened When I stopped the Flink task on the page, the worker node log reported an error and failed to send the kill signal ### What you expected to happen ![image](https://github.com/user-attachments/assets/dd6bdd6a-dcfc-400b-9588-5ed4da98343c) ### How to reproduce Run a task for a Flink component node and then stop through the page. ### Anything else _No response_ ### Version 3.2.x ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

(4 comments) (0 reactions) (0 assignees)Java (11,659 stars) (4,324 forks)batch import

buggood first issue

説明

Search before asking

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

What happened

When I stopped the Flink task on the page, the worker node log reported an error and failed to send the kill signal

What you expected to happen

How to reproduce

Run a task for a Flink component node and then stop through the page.

Anything else

No response

Version

3.2.x

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

コントリビューターガイド

技術スタック: java
領域: backenddata
Issue 種別: bug
難度: 3
推定時間: 1-2 days
活動状況: active
明確さ: mostly clear
前提条件: JavaFlinkDolphinScheduler worker process
初心者向け度: 50
調査方針: Examine the worker node code responsible for stopping Flink tasks, likely in `dolphinscheduler worker/src/main/java/org/apache/dolphinscheduler/worker/task/flink/`. Focus on the kill signal sending mechanism. Review the 4 comments on the issue for additional context and potential solutions.