more changes

2013-04-10 20:21:26 -07:00 · 2013-04-10 20:21:26 -07:00 · 465b78b4bc
parent eaea8ae163
commit 465b78b4bc
1 changed files with 5 additions and 0 deletions
--- a/merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
+++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
@ -256,6 +256,11 @@ public class RemoteTaskRunner implements TaskRunner, TaskLogProvider
  @Override
  public void shutdown(String taskId)
  {
+    if (pendingTasks.containsKey(taskId)) {
+      pendingTasks.remove(taskId);
+      return;
+    }
+
    final ZkWorker zkWorker = findWorkerRunningTask(taskId);

    if (zkWorker == null) {