diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java index 4fa1d21d3d5..080726f6b6f 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java @@ -709,8 +709,8 @@ public class HttpRemoteTaskRunner implements WorkerTaskRunner, TaskLogStreamer if (!taskItem.getResult().isDone()) { log.warn( "Failing task[%s] because worker[%s] disappeared and did not report within cleanup timeout[%s].", - workerHostAndPort, taskItem.getTaskId(), + workerHostAndPort, config.getTaskCleanupTimeout() ); // taskComplete(..) must be called outside of statusLock, see comments on method.