From 1fd177039d066e7af3f6afb190ebad52a96308f1 Mon Sep 17 00:00:00 2001 From: Parag Jain Date: Mon, 8 May 2017 17:08:25 -0500 Subject: [PATCH] fix auto reset - pause task instead of putting thread to sleep (#4244) --- .../src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java b/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java index eef8aac5d71..8edda9e52b9 100644 --- a/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java +++ b/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java @@ -1063,10 +1063,10 @@ public class KafkaIndexTask extends AbstractTask implements ChatHandler .emit(); // wait for being killed by supervisor try { - Thread.sleep(Long.MAX_VALUE); + pause(-1); } catch (InterruptedException e) { - throw new RuntimeException("Got interrupted while waiting to be killed"); + throw new RuntimeException("Got interrupted while pausing task"); } } else { log.makeAlert("Failed to send reset request for partitions [%s]", partitionOffsetMap.keySet()).emit();