apache/dolphinscheduler

[Bug] [Flink] stop flink job error

Open

#16,789 建立於 2024年11月11日

在 GitHub 查看
 (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

image

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

貢獻者指南

技術棧
java
領域
backenddata
議題類型
bug
難度面向新貢獻者的預計實作難度，1 表示很小改動，5 表示專家級工作。
3
預計時間有經驗貢獻者完成調查、實作、測試並準備 pull request 的粗略時間範圍。
1-2 days
活動狀態議題目前的可參與程度：新鮮、活躍、陳舊、阻塞或等待維護者輸入。
active
清晰度議題是否清楚說明預期改動、驗收標準和下一步。
mostly clear
前置要求
JavaFlinkDolphinScheduler worker process
新手友善度1-100 的估計分數，表示該議題對首次貢獻者的友善程度。
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.