[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 评论) (0 反应) (0 负责人)Java (11,659 star) (4,324 fork)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
议题类型: 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.