I forgot to say one more thing. This code is called only when tasks are running more than `taskDuration`. I don't know what's the idea behind doing checkpoint per taskDuration, but it expects to stop/kill all running tasks. See https://github.com/apache/incubator-druid/blob/master/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/supervisor/KafkaSupervisor.java#L1433.
[ Full content available at: https://github.com/apache/incubator-druid/pull/6206 ] This message was relayed via gitbox.apache.org for [email protected]
