mirror of https://github.com/apache/druid.git
TaskConsumer: Less complainy when interrupted
This commit is contained in:
parent
e5f46f2a66
commit
243e70a3c0
|
@ -86,8 +86,9 @@ public class TaskConsumer implements Runnable
|
||||||
task = queue.take();
|
task = queue.take();
|
||||||
}
|
}
|
||||||
catch (InterruptedException e) {
|
catch (InterruptedException e) {
|
||||||
log.info(e, "Interrupted while waiting for new work");
|
log.info("Interrupted while waiting for new work");
|
||||||
throw e;
|
Thread.currentThread().interrupt();
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|
Loading…
Reference in New Issue