ronyang1985 commented on issue #8402: URL: https://github.com/apache/dolphinscheduler/issues/8402#issuecomment-1048712323
@Meggie4 I studied the code of ds, when the task is stopped with Exception , or when the manual operation is stopped, it will try to kill the yarn job. The yarn appid is found through logs. yarn job will not be killed if yarn appid is not displayed normally in logs.The related implementations are in these two classes https://github.com/apache/dolphinscheduler/blob/6974aa3d12501a6c8a47528da7d2d6a09a6fa4ae/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThread.java#L194 https://github.com/apache/dolphinscheduler/blob/6974aa3d12501a6c8a47528da7d2d6a09a6fa4ae/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskKillProcessor.java#L138 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
