[GitHub] pdeva opened a new issue #6169: task not being scheduled even when plenty of capacity is available

[GitBox]

pdeva opened a new issue #6169: task not being scheduled even when plenty of 
capacity is available
URL: https://github.com/apache/incubator-druid/issues/6169
 
 
   not sure if this related to #6166 but it happened right after that issue.
   
   the node (on which this task can be scheuled) has '4' extra capacity left.
   
   logs:
   
   ```
   2018-08-13 19:35:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:35:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3664}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:35:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:35:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:35:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:35:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3694}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:35:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:34:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:34:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:34:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3724}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:34:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:34:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:34:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:34:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3754}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:34:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:33:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:33:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:33:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3784}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:33:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:33:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:33:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:33:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3814}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:33:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:32:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:32:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:32:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3844}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:32:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:32:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:32:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:32:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3874}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:32:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:31:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:31:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:31:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3904}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:31:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:31:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:31:07,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:31:07.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3934}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:31:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:30:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:30:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:30:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3964}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:30:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:30:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:30:07,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:30:07.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=3994}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:30:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:29:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:29:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:29:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4024}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:29:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:29:22,901 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:29:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:29:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4054}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:29:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:28:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:28:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:28:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4084}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:28:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:28:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:28:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:28:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4114}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:28:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:27:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:27:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:27:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4144}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:27:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:27:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:27:07,896 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:27:07.896Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4174}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:27:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:26:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:26:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:26:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4204}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:26:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:26:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:26:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:26:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4234}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:26:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:25:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:25:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:25:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4264}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:25:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:25:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:25:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:25:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4294}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:25:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:24:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:24:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:24:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4324}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:24:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:24:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:24:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:24:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4354}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:24:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:23:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:23:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:23:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4384}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:23:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:23:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:23:07,902 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:23:07.902Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4414}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:23:07,895 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:23:04,136 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:23:04.136Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4418}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:23:04,130 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:22:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:22:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:22:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4444}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:22:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:22:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:22:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:22:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4474}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:22:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:21:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:21:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:21:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4504}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:21:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:21:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:21:07,895 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:21:07.895Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4534}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:21:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:20:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:20:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:20:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4564}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:20:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:20:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:20:07,904 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:20:07.904Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4594}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:20:07,897 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:19:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:19:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:19:37.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4624}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:19:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:19:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:19:07,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:19:07.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4654}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:19:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:18:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:18:37,902 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:18:37.902Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4684}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:18:37,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:18:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:18:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:18:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4714}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:18:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:17:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:17:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:17:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4744}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:17:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:17:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:17:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:17:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4774}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:17:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:16:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:16:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:16:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4804}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:16:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:16:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:16:07,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:16:07.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4834}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:16:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:15:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:15:37,903 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:15:37.903Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4864}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:15:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:15:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:15:07,910 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:15:07.909Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4894}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:15:07,901 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:14:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:14:37,902 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:14:37.902Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4924}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:14:37,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:14:22,887 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:14:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:14:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4954}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:14:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:13:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:13:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:13:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=4984}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:13:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:13:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:13:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:13:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5014}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:13:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:12:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:12:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:12:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5044}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:12:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:12:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:12:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:12:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5074}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:12:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:11:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:11:37,904 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:11:37.903Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5104}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:11:37,895 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:11:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:11:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:11:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5134}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:11:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:10:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:10:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:10:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5164}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:10:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:10:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:10:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:10:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5194}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:10:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:09:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:09:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:09:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5224}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:09:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:09:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:09:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:09:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5254}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:09:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:08:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:08:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:08:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5284}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:08:37,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:08:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:08:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:08:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5314}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:08:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:07:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:07:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:07:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5344}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:07:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:07:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:07:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:07:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5374}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:07:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:06:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:06:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:06:37.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5404}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:06:37,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:06:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:06:07,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:06:07.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5434}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:06:07,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:05:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:05:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:05:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5464}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:05:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:05:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:05:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:05:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5494}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:05:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:04:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:04:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:04:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5524}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:04:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:04:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:04:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:04:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5554}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:04:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:03:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:03:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:03:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5584}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:03:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:03:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:03:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:03:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5614}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:03:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:02:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:02:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:02:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5644}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:02:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:02:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:02:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:02:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5674}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:02:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:01:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:01:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:01:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5704}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:01:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:01:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:01:07,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:01:07.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5734}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:01:07,895 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:00:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:00:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:00:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5764}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:00:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:00:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 19:00:07,896 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T19:00:07.896Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5794}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 19:00:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:59:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:59:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:59:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5824}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:59:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:59:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:59:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:59:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5854}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:59:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:58:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:58:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:58:37.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5884}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:58:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:58:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:58:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:58:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5914}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:58:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:57:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:57:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:57:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5944}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:57:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:57:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:57:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:57:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5974}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:57:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:56:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:56:51,361 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:56:51.361Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=5990}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:56:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:56:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:56:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:56:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6034}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:56:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:55:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:55:37,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:55:37.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6064}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:55:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:55:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:55:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:55:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6094}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:55:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:54:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:54:37,902 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:54:37.902Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6124}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:54:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:54:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:54:07,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:54:07.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6154}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:54:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:53:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:53:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:53:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6184}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:53:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:53:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:53:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:53:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6214}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:53:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:52:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:52:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:52:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6244}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:52:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:52:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:52:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:52:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6274}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:52:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:51:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:51:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:51:37.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6304}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:51:37,895 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:51:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:51:07,897 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:51:07.897Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6334}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:51:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:50:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:50:37,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:50:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6364}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:50:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:50:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:50:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:50:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6394}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:50:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:49:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:49:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:49:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6424}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:49:37,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:49:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:49:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:49:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6454}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:49:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:48:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:48:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:48:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6484}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:48:37,894 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:48:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:48:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:48:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6514}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:48:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:47:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:47:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:47:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6544}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:47:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:47:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:47:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:47:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6574}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:47:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:46:52,890 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:46:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:46:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6604}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:46:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:46:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:46:07,914 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:46:07.914Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6634}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:46:07,907 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:45:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:45:37,902 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:45:37.902Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6664}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:45:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:45:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:45:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:45:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6694}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:45:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:44:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:44:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:44:37.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6724}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:44:37,890 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:44:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:44:07,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:44:07.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6754}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:44:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:43:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:43:37,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:43:37.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6784}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:43:37,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:43:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:43:07,896 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:43:07.896Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6814}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:43:07,890 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:42:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:42:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:42:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6844}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:42:37,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:42:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:42:07,898 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:42:07.898Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6874}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:42:07,891 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:41:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:41:37,900 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:41:37.900Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6904}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:41:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:41:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:41:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:41:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6934}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:41:07,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:40:52,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:40:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:40:37.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6964}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:40:37,892 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:40:22,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:40:07,899 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:40:07.899Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=6994}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:40:07,893 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:52,888 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:37,901 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:39:37.901Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=7024}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:39:37,895 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:22,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:10,263 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:39:10.263Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=7052}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:39:10,256 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-0] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:07,911 INFO i.d.i.k.s.KafkaSupervisor 
[KafkaSupervisor-pctile-hour] {id='pctile-hour', 
generationTime=2018-08-13T18:39:07.911Z, payload={dataSource='pctile-hour', 
topic='dupercentile', partitions=1, replicas=2, durationSeconds=86400, 
active=[{id='index_kafka_pctile-hour_cc3ace5c8734d83_mmcdboja', 
startTime=2018-08-12T20:36:42.320Z, remainingSeconds=7054}, 
{id='index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh', startTime=null, 
remainingSeconds=null}], publishing=[]}}
   2018-08-13 18:39:07,905 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:07,897 WARN i.d.i.k.s.KafkaSupervisor 
[KafkaIndexTaskClient-pctile-hour-1] Ignoring task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], as probably it is not 
started running yet
   2018-08-13 18:39:07,896 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:07,889 INFO i.d.i.k.KafkaIndexTaskClient 
[KafkaIndexTaskClient-pctile-hour-1] No TaskLocation available for task 
[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh], this task may not have been 
assigned to a worker yet or may have already completed
   2018-08-13 18:39:05,245 INFO i.d.i.o.RemoteTaskRunner [TaskQueue-Manager] 
Added pending task index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh
   2018-08-13 18:39:05,245 INFO i.d.i.o.TaskQueue [TaskQueue-Manager] Asking 
taskRunner to run: index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh
   2018-08-13 18:39:05,245 INFO i.d.i.o.TaskLockbox 
[KafkaSupervisor-pctile-hour] Adding 
task[index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh] to activeTasks
   2018-08-13 18:39:05,239 INFO i.d.i.o.MetadataTaskStorage 
[KafkaSupervisor-pctile-hour] Inserting task 
index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh with status: 
TaskStatus{id=index_kafka_pctile-hour_cc3ace5c8734d83_hbhfekmh, status=RUNNING, 
duration=-1}
   
   ```
   
   the MM node is 0.12.2
   the overlord+coord node is 0.12.1

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org