apache/dolphinscheduler

[Bug] [Flink] stop flink job error

Open

Aperta il 11 nov 2024

Vedi su GitHub
 (4 commenti) (0 reazioni) (0 assegnatari)Java (11.659 star) (4324 fork)batch import
buggood first issue

Descrizione

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

Guida contributor

Tech stack
java
Dominio
backenddata
Tipo issue
bug
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-2 days
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
active
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
mostly clear
Prerequisiti
JavaFlinkDolphinScheduler worker process
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
50
Direzione di ricerca
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.