diff --git a/indexing-service/src/main/java/io/druid/indexing/worker/WorkerTaskMonitor.java b/indexing-service/src/main/java/io/druid/indexing/worker/WorkerTaskMonitor.java index 51ad98adaf2..3e31461cecf 100644 --- a/indexing-service/src/main/java/io/druid/indexing/worker/WorkerTaskMonitor.java +++ b/indexing-service/src/main/java/io/druid/indexing/worker/WorkerTaskMonitor.java @@ -108,6 +108,8 @@ public class WorkerTaskMonitor return; } + log.info("Submitting runnable for task[%s]", task.getId()); + exec.submit( new Runnable() {