diff --git a/merger/src/main/java/com/metamx/druid/merger/coordinator/exec/TaskConsumer.java b/merger/src/main/java/com/metamx/druid/merger/coordinator/exec/TaskConsumer.java
index dc39f6e3282..4d086368bc8 100644
--- a/merger/src/main/java/com/metamx/druid/merger/coordinator/exec/TaskConsumer.java
+++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/exec/TaskConsumer.java
@@ -86,8 +86,9 @@ public class TaskConsumer implements Runnable
           task = queue.take();
         }
         catch (InterruptedException e) {
-          log.info(e, "Interrupted while waiting for new work");
-          throw e;
+          log.info("Interrupted while waiting for new work");
+          Thread.currentThread().interrupt();
+          break;
         }
 
         try {