From dcd10e69c720d7281a1a92ce0235e177e843eac8 Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Sun, 24 Mar 2013 18:19:32 -0700 Subject: [PATCH] WorkerTaskMonitor: Fix isTaskRunning check --- .../java/com/metamx/druid/merger/worker/WorkerTaskMonitor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 400abec76fe..02e95a0ef39 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; } }