From 243e70a3c059969226942e2690d2e474d11055db Mon Sep 17 00:00:00 2001
From: Gian Merlino <gianmerlino@gmail.com>
Date: Tue, 19 Mar 2013 16:31:37 -0700
Subject: [PATCH] TaskConsumer: Less complainy when interrupted

---
 .../metamx/druid/merger/coordinator/exec/TaskConsumer.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 {