jon-wei commented on a change in pull request #12052:
URL: https://github.com/apache/druid/pull/12052#discussion_r768127129
##########
File path:
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTask.java
##########
@@ -502,7 +504,7 @@ private void initializeSubTaskCleaner()
if (isParallelMode()) {
currentSubTaskHolder = new CurrentSubTaskHolder((currentRunnerObject,
taskConfig) -> {
final ParallelIndexTaskRunner runner = (ParallelIndexTaskRunner)
currentRunnerObject;
- runner.stopGracefully();
+ runner.stopGracefully(null);
Review comment:
I left this as is, I don't think it'd really add much and it would need
to be checked elsewhere to see that it doesn't override the error message on
task failure
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
