Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 07:25:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix auto reset - pause task instead of putting thread to sleep (#4244)

Browse Source
This commit is contained in:
Parag Jain 2017-05-08 17:08:25 -05:00 committed by Fangjin Yang
parent eb8e1b0a97
commit 1fd177039d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java
View File

@ -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();