diff --git a/merger/src/main/java/com/metamx/druid/merger/worker/WorkerTaskMonitor.java b/merger/src/main/java/com/metamx/druid/merger/worker/WorkerTaskMonitor.java
index <HASH>..<HASH> 100644
--- a/merger/src/main/java/com/metamx/druid/merger/worker/WorkerTaskMonitor.java
+++ b/merger/src/main/java/com/metamx/druid/merger/worker/WorkerTaskMonitor.java
@@ -175,7 +175,7 @@ public class WorkerTaskMonitor implements QuerySegmentWalker
   private boolean isTaskRunning(final Task task)
   {
     for (final Task runningTask : running) {
-      if (runningTask.equals(task.getId())) {
+      if (runningTask.getId().equals(task.getId())) {
         return true;
       }
     }
WorkerTaskMonitor: Fix isTaskRunning check