Call stopGracefully() when batch ingestion is killed explicitly#8075
Call stopGracefully() when batch ingestion is killed explicitly#8075ankit0811 wants to merge 1 commit intoapache:masterfrom
Conversation
…estion task is killed, the control does to the ForkingTaskRunner::shutdown
|
Hmm, @ankit0811 do you know why |
|
The ingestion task was issued a kill command by clicking the kill link on the UI |
Do you mean the Druid task issued a kill command to kill Hadoop job? or you issued a kill command to kill the Druid task? If it's the later case, then it sounds like something went wrong with the kill command issued to the Druid task. How did you know |
|
Yes, it is the later case. And yes the log line is not printed |
|
#8085 fixes a logging issue so we can be sure that lifecycle stop is happening, but I don't believe it fixes the issue with the Hadoop task not getting killed, see here for more details. |
Fixes #7962.
Fixed by calling task.stopGracefully() from ForkingTaskRunner when hadoop ingestion task is killed, as the control goes to the ForkingTaskRunner::shutdown
and not to SingleTaskBackgroundRunner::stop
This PR has:
been self-reviewed.
been tested in a test Druid cluster.