Created
June 5, 2018 02:04
-
-
Save ChenShuai1981/d948aca8f13af9cf0375a443c8e3433b to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2018-06-04T12:05:42,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:05:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:05:42.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=433}]}} | |
| 2018-06-04T12:05:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:05:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2293}], publishing=[]}} | |
| 2018-06-04T12:05:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:05:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2294}], publishing=[]}} | |
| 2018-06-04T12:05:57,229 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:05:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:05:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:05:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:05:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:05:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:05:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:06:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:06:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:06:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2225}], publishing=[]}} | |
| 2018-06-04T12:06:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:06:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2285}], publishing=[]}} | |
| 2018-06-04T12:06:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:06:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2264}], publishing=[]}} | |
| 2018-06-04T12:06:12,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:06:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:06:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=403}]}} | |
| 2018-06-04T12:06:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:06:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2263}], publishing=[]}} | |
| 2018-06-04T12:06:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:06:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2264}], publishing=[]}} | |
| 2018-06-04T12:06:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:06:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:06:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:06:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:06:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:06:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:06:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:06:35,426 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:06:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:06:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2195}], publishing=[]}} | |
| 2018-06-04T12:06:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:06:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2255}], publishing=[]}} | |
| 2018-06-04T12:06:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:06:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2234}], publishing=[]}} | |
| 2018-06-04T12:06:42,470 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:06:42,473 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:06:42.473Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=373}]}} | |
| 2018-06-04T12:06:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:06:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2233}], publishing=[]}} | |
| 2018-06-04T12:06:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:06:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2234}], publishing=[]}} | |
| 2018-06-04T12:06:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:06:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:06:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:06:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:06:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:06:57,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:06:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:07:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:07:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:07:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2165}], publishing=[]}} | |
| 2018-06-04T12:07:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:07:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2225}], publishing=[]}} | |
| 2018-06-04T12:07:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:07:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2204}], publishing=[]}} | |
| 2018-06-04T12:07:12,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:07:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:07:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=343}]}} | |
| 2018-06-04T12:07:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:07:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2203}], publishing=[]}} | |
| 2018-06-04T12:07:12,621 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:07:12.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2204}], publishing=[]}} | |
| 2018-06-04T12:07:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:07:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:07:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:07:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:07:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:07:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:07:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:07:35,426 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:07:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:07:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2135}], publishing=[]}} | |
| 2018-06-04T12:07:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:07:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2195}], publishing=[]}} | |
| 2018-06-04T12:07:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:07:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2174}], publishing=[]}} | |
| 2018-06-04T12:07:42,470 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:07:42,472 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:07:42.472Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=313}]}} | |
| 2018-06-04T12:07:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:07:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2173}], publishing=[]}} | |
| 2018-06-04T12:07:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:07:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2174}], publishing=[]}} | |
| 2018-06-04T12:07:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:07:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:07:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:07:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:07:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:07:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:07:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:08:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:08:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:08:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2105}], publishing=[]}} | |
| 2018-06-04T12:08:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:08:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2165}], publishing=[]}} | |
| 2018-06-04T12:08:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:08:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2144}], publishing=[]}} | |
| 2018-06-04T12:08:12,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:08:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:08:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=283}]}} | |
| 2018-06-04T12:08:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:08:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2143}], publishing=[]}} | |
| 2018-06-04T12:08:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:08:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2144}], publishing=[]}} | |
| 2018-06-04T12:08:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:08:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:08:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:08:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:08:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:08:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:08:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:08:35,426 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:08:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:08:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2075}], publishing=[]}} | |
| 2018-06-04T12:08:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:08:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2135}], publishing=[]}} | |
| 2018-06-04T12:08:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:08:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2114}], publishing=[]}} | |
| 2018-06-04T12:08:42,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:08:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:08:42.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=253}]}} | |
| 2018-06-04T12:08:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:08:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2113}], publishing=[]}} | |
| 2018-06-04T12:08:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:08:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2114}], publishing=[]}} | |
| 2018-06-04T12:08:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:08:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:08:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:08:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:08:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:08:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:08:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:09:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:09:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:09:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2045}], publishing=[]}} | |
| 2018-06-04T12:09:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:09:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2105}], publishing=[]}} | |
| 2018-06-04T12:09:12,393 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:09:12.393Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2084}], publishing=[]}} | |
| 2018-06-04T12:09:12,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:09:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:09:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=223}]}} | |
| 2018-06-04T12:09:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:09:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2083}], publishing=[]}} | |
| 2018-06-04T12:09:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:09:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2084}], publishing=[]}} | |
| 2018-06-04T12:09:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:09:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:09:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:09:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:09:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:09:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:09:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:09:35,426 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:09:42,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:09:42.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=2015}], publishing=[]}} | |
| 2018-06-04T12:09:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:09:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2075}], publishing=[]}} | |
| 2018-06-04T12:09:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:09:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2054}], publishing=[]}} | |
| 2018-06-04T12:09:42,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:09:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:09:42.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=193}]}} | |
| 2018-06-04T12:09:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:09:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2053}], publishing=[]}} | |
| 2018-06-04T12:09:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:09:42.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2054}], publishing=[]}} | |
| 2018-06-04T12:09:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:09:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:09:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:09:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:09:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:09:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:09:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:10:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:10:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:10:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1985}], publishing=[]}} | |
| 2018-06-04T12:10:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:10:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2045}], publishing=[]}} | |
| 2018-06-04T12:10:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:10:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=2024}], publishing=[]}} | |
| 2018-06-04T12:10:12,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:10:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:10:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=163}]}} | |
| 2018-06-04T12:10:12,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:10:12.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=2023}], publishing=[]}} | |
| 2018-06-04T12:10:12,624 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:10:12.624Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=2024}], publishing=[]}} | |
| 2018-06-04T12:10:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:10:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:10:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:10:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:10:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:10:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:10:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:10:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:10:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:10:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1955}], publishing=[]}} | |
| 2018-06-04T12:10:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:10:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=2015}], publishing=[]}} | |
| 2018-06-04T12:10:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:10:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1994}], publishing=[]}} | |
| 2018-06-04T12:10:42,470 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:10:42,472 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:10:42.472Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=133}]}} | |
| 2018-06-04T12:10:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:10:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1993}], publishing=[]}} | |
| 2018-06-04T12:10:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:10:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1994}], publishing=[]}} | |
| 2018-06-04T12:10:57,229 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:10:57,320 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:10:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:10:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:10:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:10:57,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:10:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:11:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:11:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:11:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1925}], publishing=[]}} | |
| 2018-06-04T12:11:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:11:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1985}], publishing=[]}} | |
| 2018-06-04T12:11:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:11:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1964}], publishing=[]}} | |
| 2018-06-04T12:11:12,470 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:11:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:11:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=103}]}} | |
| 2018-06-04T12:11:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:11:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1963}], publishing=[]}} | |
| 2018-06-04T12:11:12,621 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:11:12.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1964}], publishing=[]}} | |
| 2018-06-04T12:11:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:11:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:11:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:11:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:11:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:11:27,571 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:11:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:11:35,426 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:11:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:11:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1895}], publishing=[]}} | |
| 2018-06-04T12:11:42,307 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:11:42.307Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1955}], publishing=[]}} | |
| 2018-06-04T12:11:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:11:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1934}], publishing=[]}} | |
| 2018-06-04T12:11:42,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:11:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:11:42.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=73}]}} | |
| 2018-06-04T12:11:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:11:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1933}], publishing=[]}} | |
| 2018-06-04T12:11:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:11:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1934}], publishing=[]}} | |
| 2018-06-04T12:11:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:11:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:11:57,409 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:11:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:11:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:11:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:11:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:12:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:12:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:12:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1865}], publishing=[]}} | |
| 2018-06-04T12:12:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:12:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1925}], publishing=[]}} | |
| 2018-06-04T12:12:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:12:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1904}], publishing=[]}} | |
| 2018-06-04T12:12:12,469 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:12:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:12:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=43}]}} | |
| 2018-06-04T12:12:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:12:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1903}], publishing=[]}} | |
| 2018-06-04T12:12:12,621 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:12:12.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1904}], publishing=[]}} | |
| 2018-06-04T12:12:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:12:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:12:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:12:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:12:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:12:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:12:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:12:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 7 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:12:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:12:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1835}], publishing=[]}} | |
| 2018-06-04T12:12:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:12:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1895}], publishing=[]}} | |
| 2018-06-04T12:12:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:12:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1874}], publishing=[]}} | |
| 2018-06-04T12:12:42,470 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:12:42,472 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:12:42.472Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof', startTime=null, remainingSeconds=null}], publishing=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk', startTime=2018-06-04T10:42:55.209Z, remainingSeconds=13}]}} | |
| 2018-06-04T12:12:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:12:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1873}], publishing=[]}} | |
| 2018-06-04T12:12:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:12:42.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1874}], publishing=[]}} | |
| 2018-06-04T12:12:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:12:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:12:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:12:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:12:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:12:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:12:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:13:07,513 WARN [KafkaSupervisor-preprod-risk-invocation-history-kafka-Reporting-0] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Lag metric: Kafka partitions [0] do not match task partitions [] | |
| 2018-06-04T12:13:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:13:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1805}], publishing=[]}} | |
| 2018-06-04T12:13:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:13:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1865}], publishing=[]}} | |
| 2018-06-04T12:13:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:13:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1844}], publishing=[]}} | |
| 2018-06-04T12:13:12,470 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.indexing.kafka.KafkaIndexTaskClient - No TaskLocation available for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof], this task may not have been assigned to a worker yet or may have already completed | |
| 2018-06-04T12:13:12,470 ERROR [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - No task in [[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk]] succeeded before the completion timeout elapsed [PT1800S]!: {class=io.druid.indexing.kafka.supervisor.KafkaSupervisor} | |
| 2018-06-04T12:13:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Killing task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] in the task group | |
| 2018-06-04T12:13:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8091 | |
| 2018-06-04T12:13:12,475 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.RemoteTaskRunner - Sent shutdown message to worker: iZuf6flaph02htekc965qjZ:8091, status 200 OK, response: {"task":"index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk"} | |
| 2018-06-04T12:13:12,475 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.TaskLockbox - Removing task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] from activeTasks | |
| 2018-06-04T12:13:12,476 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.MetadataTaskStorage - Updating task index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk to status: TaskStatus{id=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk, status=FAILED, duration=-1} | |
| 2018-06-04T12:13:12,482 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.TaskQueue - Task done: KafkaIndexTask{id=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk, type=index_kafka, dataSource=preprod-risk-invocation-history-kafka} | |
| 2018-06-04T12:13:12,482 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Killing task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof] in the task group | |
| 2018-06-04T12:13:12,482 INFO [TaskQueue-Manager] io.druid.indexing.overlord.TaskQueue - Asking taskRunner to clean up 1 tasks. | |
| 2018-06-04T12:13:12,483 INFO [TaskQueue-Manager] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8091 | |
| 2018-06-04T12:13:12,486 INFO [TaskQueue-Manager] io.druid.indexing.overlord.RemoteTaskRunner - Sent shutdown message to worker: iZuf6flaph02htekc965qjZ:8091, status 200 OK, response: {"task":"index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk"} | |
| 2018-06-04T12:13:12,486 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.RemoteTaskRunner - Removed task from pending queue: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof | |
| 2018-06-04T12:13:12,486 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.TaskLockbox - Removing task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof] from activeTasks | |
| 2018-06-04T12:13:12,487 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.MetadataTaskStorage - Updating task index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof to status: TaskStatus{id=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof, status=FAILED, duration=-1} | |
| 2018-06-04T12:13:12,491 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.TaskQueue - Task done: KafkaIndexTask{id=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_fbjlhfof, type=index_kafka, dataSource=preprod-risk-invocation-history-kafka} | |
| 2018-06-04T12:13:12,491 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Creating new task group [0] for partitions [0] | |
| 2018-06-04T12:13:12,491 INFO [TaskQueue-Manager] io.druid.indexing.overlord.TaskQueue - Asking taskRunner to clean up 1 tasks. | |
| 2018-06-04T12:13:12,493 INFO [TaskQueue-Manager] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8091 | |
| 2018-06-04T12:13:12,500 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Number of tasks [0] does not match configured numReplicas [1] in task group [0], creating more tasks | |
| 2018-06-04T12:13:12,501 INFO [TaskQueue-Manager] io.druid.indexing.overlord.RemoteTaskRunner - Sent shutdown message to worker: iZuf6flaph02htekc965qjZ:8091, status 200 OK, response: {"task":"index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk"} | |
| 2018-06-04T12:13:12,502 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.MetadataTaskStorage - Inserting task index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea with status: TaskStatus{id=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea, status=RUNNING, duration=-1} | |
| 2018-06-04T12:13:12,510 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.overlord.TaskLockbox - Adding task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] to activeTasks | |
| 2018-06-04T12:13:12,510 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:13:12.510Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[], publishing=[]}} | |
| 2018-06-04T12:13:12,514 INFO [TaskQueue-Manager] io.druid.indexing.overlord.TaskQueue - Asking taskRunner to run: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea | |
| 2018-06-04T12:13:12,514 INFO [TaskQueue-Manager] io.druid.indexing.overlord.RemoteTaskRunner - Added pending task index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea | |
| 2018-06-04T12:13:12,514 INFO [TaskQueue-Manager] io.druid.indexing.overlord.TaskQueue - Asking taskRunner to clean up 1 tasks. | |
| 2018-06-04T12:13:12,515 INFO [TaskQueue-Manager] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8091 | |
| 2018-06-04T12:13:12,519 INFO [TaskQueue-Manager] io.druid.indexing.overlord.RemoteTaskRunner - Sent shutdown message to worker: iZuf6flaph02htekc965qjZ:8091, status 200 OK, response: {"task":"index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk"} | |
| 2018-06-04T12:13:12,527 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.RemoteTaskRunner - Worker[iZuf6flaph02htekc965qjZ:8091] wrote FAILED status for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] on [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8103, tlsPort=-1}] | |
| 2018-06-04T12:13:12,527 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.RemoteTaskRunner - Worker[iZuf6flaph02htekc965qjZ:8091] completed task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] with status[FAILED] | |
| 2018-06-04T12:13:12,527 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.TaskQueue - Received FAILED status for task: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,527 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.RemoteTaskRunner - Cleaning up task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] on worker[iZuf6flaph02htekc965qjZ:8091] | |
| 2018-06-04T12:13:12,528 WARN [Curator-PathChildrenCache-1] io.druid.indexing.overlord.TaskQueue - Unknown task completed: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,528 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.TaskQueue - Task FAILED: KafkaIndexTask{id=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk, type=index_kafka, dataSource=preprod-risk-invocation-history-kafka} (5423336 run duration) | |
| 2018-06-04T12:13:12,528 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] status changed to [FAILED]. | |
| 2018-06-04T12:13:12,528 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.RemoteTaskRunner - Task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] went bye bye. | |
| 2018-06-04T12:13:12,528 INFO [rtr-pending-tasks-runner-0] io.druid.indexing.overlord.RemoteTaskRunner - Coordinator asking Worker[iZuf6flaph02htekc965qjZ:8091] to add task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] | |
| 2018-06-04T12:13:12,533 INFO [rtr-pending-tasks-runner-0] io.druid.indexing.overlord.RemoteTaskRunner - Task index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea switched from pending to running (on [iZuf6flaph02htekc965qjZ:8091]) | |
| 2018-06-04T12:13:12,533 INFO [rtr-pending-tasks-runner-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] status changed to [RUNNING]. | |
| 2018-06-04T12:13:12,534 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:13:12.534Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1844}], publishing=[]}} | |
| 2018-06-04T12:13:12,534 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:13:12.534Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1844}], publishing=[]}} | |
| 2018-06-04T12:13:12,539 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.RemoteTaskRunner - Worker[iZuf6flaph02htekc965qjZ:8091] wrote RUNNING status for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] on [TaskLocation{host='null', port=-1, tlsPort=-1}] | |
| 2018-06-04T12:13:12,559 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.RemoteTaskRunner - Worker[iZuf6flaph02htekc965qjZ:8091] wrote RUNNING status for task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] on [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8103, tlsPort=-1}] | |
| 2018-06-04T12:13:12,559 INFO [Curator-PathChildrenCache-1] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8103, tlsPort=-1}]. | |
| 2018-06-04T12:13:19,517 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:13:19,665 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:13:19,673 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Setting taskGroup sequences to [{0={0=1614}}] for group [0] | |
| 2018-06-04T12:13:19,675 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:13:19,680 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:13:19.680Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3598}], publishing=[]}} | |
| 2018-06-04T12:13:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:13:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:13:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:13:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:13:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:13:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:13:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:13:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:13:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1775}], publishing=[]}} | |
| 2018-06-04T12:13:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:13:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1835}], publishing=[]}} | |
| 2018-06-04T12:13:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:13:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1814}], publishing=[]}} | |
| 2018-06-04T12:13:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:13:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3575}], publishing=[]}} | |
| 2018-06-04T12:13:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:13:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1813}], publishing=[]}} | |
| 2018-06-04T12:13:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:13:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1814}], publishing=[]}} | |
| 2018-06-04T12:13:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:13:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:13:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:13:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:13:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:13:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:14:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:14:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1745}], publishing=[]}} | |
| 2018-06-04T12:14:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:14:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1805}], publishing=[]}} | |
| 2018-06-04T12:14:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:14:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1784}], publishing=[]}} | |
| 2018-06-04T12:14:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:14:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3545}], publishing=[]}} | |
| 2018-06-04T12:14:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:14:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1783}], publishing=[]}} | |
| 2018-06-04T12:14:12,621 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:14:12.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1784}], publishing=[]}} | |
| 2018-06-04T12:14:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:14:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:14:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:14:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:14:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:14:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:14:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:14:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:14:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1715}], publishing=[]}} | |
| 2018-06-04T12:14:42,307 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:14:42.307Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1775}], publishing=[]}} | |
| 2018-06-04T12:14:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:14:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1754}], publishing=[]}} | |
| 2018-06-04T12:14:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:14:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3515}], publishing=[]}} | |
| 2018-06-04T12:14:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:14:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1753}], publishing=[]}} | |
| 2018-06-04T12:14:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:14:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1754}], publishing=[]}} | |
| 2018-06-04T12:14:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:14:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:14:57,409 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:14:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:14:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:14:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:15:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:15:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1685}], publishing=[]}} | |
| 2018-06-04T12:15:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:15:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1745}], publishing=[]}} | |
| 2018-06-04T12:15:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:15:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1724}], publishing=[]}} | |
| 2018-06-04T12:15:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:15:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3485}], publishing=[]}} | |
| 2018-06-04T12:15:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:15:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1723}], publishing=[]}} | |
| 2018-06-04T12:15:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:15:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1724}], publishing=[]}} | |
| 2018-06-04T12:15:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:15:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:15:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:15:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:15:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:15:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:15:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:15:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:15:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1655}], publishing=[]}} | |
| 2018-06-04T12:15:42,307 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:15:42.307Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1715}], publishing=[]}} | |
| 2018-06-04T12:15:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:15:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1694}], publishing=[]}} | |
| 2018-06-04T12:15:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:15:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3455}], publishing=[]}} | |
| 2018-06-04T12:15:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:15:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1693}], publishing=[]}} | |
| 2018-06-04T12:15:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:15:42.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1694}], publishing=[]}} | |
| 2018-06-04T12:15:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:15:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:15:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:15:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:15:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:15:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:16:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:16:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1625}], publishing=[]}} | |
| 2018-06-04T12:16:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:16:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1685}], publishing=[]}} | |
| 2018-06-04T12:16:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:16:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1664}], publishing=[]}} | |
| 2018-06-04T12:16:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:16:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3425}], publishing=[]}} | |
| 2018-06-04T12:16:12,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:16:12.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1663}], publishing=[]}} | |
| 2018-06-04T12:16:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:16:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1664}], publishing=[]}} | |
| 2018-06-04T12:16:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:16:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:16:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:16:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:16:27,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:16:27,632 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:16:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:16:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:16:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1595}], publishing=[]}} | |
| 2018-06-04T12:16:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:16:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1655}], publishing=[]}} | |
| 2018-06-04T12:16:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:16:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1634}], publishing=[]}} | |
| 2018-06-04T12:16:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:16:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3395}], publishing=[]}} | |
| 2018-06-04T12:16:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:16:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1633}], publishing=[]}} | |
| 2018-06-04T12:16:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:16:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1634}], publishing=[]}} | |
| 2018-06-04T12:16:57,229 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:16:57,320 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:16:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:16:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:16:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:16:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:17:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:17:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1565}], publishing=[]}} | |
| 2018-06-04T12:17:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:17:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1625}], publishing=[]}} | |
| 2018-06-04T12:17:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:17:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1604}], publishing=[]}} | |
| 2018-06-04T12:17:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:17:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3365}], publishing=[]}} | |
| 2018-06-04T12:17:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:17:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1603}], publishing=[]}} | |
| 2018-06-04T12:17:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:17:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1604}], publishing=[]}} | |
| 2018-06-04T12:17:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:17:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:17:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:17:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:17:27,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:17:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:17:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:17:42,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:17:42.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1535}], publishing=[]}} | |
| 2018-06-04T12:17:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:17:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1595}], publishing=[]}} | |
| 2018-06-04T12:17:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:17:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1574}], publishing=[]}} | |
| 2018-06-04T12:17:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:17:42.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3335}], publishing=[]}} | |
| 2018-06-04T12:17:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:17:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1573}], publishing=[]}} | |
| 2018-06-04T12:17:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:17:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1574}], publishing=[]}} | |
| 2018-06-04T12:17:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:17:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:17:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:17:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:17:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:17:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:18:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:18:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1505}], publishing=[]}} | |
| 2018-06-04T12:18:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:18:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1565}], publishing=[]}} | |
| 2018-06-04T12:18:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:18:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1544}], publishing=[]}} | |
| 2018-06-04T12:18:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:18:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3305}], publishing=[]}} | |
| 2018-06-04T12:18:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:18:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1543}], publishing=[]}} | |
| 2018-06-04T12:18:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:18:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1544}], publishing=[]}} | |
| 2018-06-04T12:18:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:18:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:18:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:18:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:18:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:18:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:18:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:18:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:18:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1475}], publishing=[]}} | |
| 2018-06-04T12:18:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:18:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1535}], publishing=[]}} | |
| 2018-06-04T12:18:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:18:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1514}], publishing=[]}} | |
| 2018-06-04T12:18:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:18:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3275}], publishing=[]}} | |
| 2018-06-04T12:18:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:18:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1513}], publishing=[]}} | |
| 2018-06-04T12:18:42,623 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:18:42.623Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1514}], publishing=[]}} | |
| 2018-06-04T12:18:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:18:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:18:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:18:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:18:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:18:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:19:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:19:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1445}], publishing=[]}} | |
| 2018-06-04T12:19:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:19:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1505}], publishing=[]}} | |
| 2018-06-04T12:19:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:19:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1484}], publishing=[]}} | |
| 2018-06-04T12:19:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:19:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3245}], publishing=[]}} | |
| 2018-06-04T12:19:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:19:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1483}], publishing=[]}} | |
| 2018-06-04T12:19:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:19:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1484}], publishing=[]}} | |
| 2018-06-04T12:19:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:19:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:19:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:19:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:19:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:19:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:19:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:19:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:19:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1415}], publishing=[]}} | |
| 2018-06-04T12:19:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:19:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1475}], publishing=[]}} | |
| 2018-06-04T12:19:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:19:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1454}], publishing=[]}} | |
| 2018-06-04T12:19:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:19:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3215}], publishing=[]}} | |
| 2018-06-04T12:19:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:19:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1453}], publishing=[]}} | |
| 2018-06-04T12:19:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:19:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1454}], publishing=[]}} | |
| 2018-06-04T12:19:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:19:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:19:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:19:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:19:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:19:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:20:12,222 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:20:12.222Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1385}], publishing=[]}} | |
| 2018-06-04T12:20:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:20:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1445}], publishing=[]}} | |
| 2018-06-04T12:20:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:20:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1424}], publishing=[]}} | |
| 2018-06-04T12:20:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:20:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3185}], publishing=[]}} | |
| 2018-06-04T12:20:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:20:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1423}], publishing=[]}} | |
| 2018-06-04T12:20:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:20:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1424}], publishing=[]}} | |
| 2018-06-04T12:20:27,229 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:20:27,320 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:20:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:20:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:20:27,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:20:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:20:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:20:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:20:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1355}], publishing=[]}} | |
| 2018-06-04T12:20:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:20:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1415}], publishing=[]}} | |
| 2018-06-04T12:20:42,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:20:42.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1394}], publishing=[]}} | |
| 2018-06-04T12:20:42,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:20:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3155}], publishing=[]}} | |
| 2018-06-04T12:20:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:20:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1393}], publishing=[]}} | |
| 2018-06-04T12:20:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:20:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1394}], publishing=[]}} | |
| 2018-06-04T12:20:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:20:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:20:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:20:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:20:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:20:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:21:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:21:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1325}], publishing=[]}} | |
| 2018-06-04T12:21:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:21:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1385}], publishing=[]}} | |
| 2018-06-04T12:21:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:21:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1364}], publishing=[]}} | |
| 2018-06-04T12:21:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:21:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3125}], publishing=[]}} | |
| 2018-06-04T12:21:12,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:21:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1363}], publishing=[]}} | |
| 2018-06-04T12:21:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:21:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1364}], publishing=[]}} | |
| 2018-06-04T12:21:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:21:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:21:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:21:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:21:27,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:21:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:21:35,428 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:21:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:21:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1295}], publishing=[]}} | |
| 2018-06-04T12:21:42,309 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:21:42.309Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1355}], publishing=[]}} | |
| 2018-06-04T12:21:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:21:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1334}], publishing=[]}} | |
| 2018-06-04T12:21:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:21:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3095}], publishing=[]}} | |
| 2018-06-04T12:21:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:21:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1333}], publishing=[]}} | |
| 2018-06-04T12:21:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:21:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1334}], publishing=[]}} | |
| 2018-06-04T12:21:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:21:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:21:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:21:57,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:21:57,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:21:57,632 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:22:12,223 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:22:12.223Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1265}], publishing=[]}} | |
| 2018-06-04T12:22:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:22:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1325}], publishing=[]}} | |
| 2018-06-04T12:22:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:22:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1304}], publishing=[]}} | |
| 2018-06-04T12:22:12,471 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:22:12.471Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3065}], publishing=[]}} | |
| 2018-06-04T12:22:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:22:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1303}], publishing=[]}} | |
| 2018-06-04T12:22:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:22:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1304}], publishing=[]}} | |
| 2018-06-04T12:22:27,229 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:22:27,320 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:22:27,411 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:22:27,478 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:22:27,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:22:27,632 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:22:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:22:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:22:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1235}], publishing=[]}} | |
| 2018-06-04T12:22:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:22:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1295}], publishing=[]}} | |
| 2018-06-04T12:22:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:22:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1274}], publishing=[]}} | |
| 2018-06-04T12:22:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:22:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3035}], publishing=[]}} | |
| 2018-06-04T12:22:42,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:22:42.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1273}], publishing=[]}} | |
| 2018-06-04T12:22:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:22:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1274}], publishing=[]}} | |
| 2018-06-04T12:22:57,229 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:22:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:22:57,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:22:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:22:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:22:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:23:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:23:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1205}], publishing=[]}} | |
| 2018-06-04T12:23:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:23:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1265}], publishing=[]}} | |
| 2018-06-04T12:23:12,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:23:12.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1244}], publishing=[]}} | |
| 2018-06-04T12:23:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:23:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=3005}], publishing=[]}} | |
| 2018-06-04T12:23:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:23:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1243}], publishing=[]}} | |
| 2018-06-04T12:23:12,621 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:23:12.621Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1244}], publishing=[]}} | |
| 2018-06-04T12:23:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:23:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:23:27,409 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:23:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:23:27,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:23:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:23:35,427 INFO [TaskQueue-StorageSync] io.druid.indexing.overlord.TaskQueue - Synced 6 tasks from storage (0 tasks added, 0 tasks removed). | |
| 2018-06-04T12:23:42,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:23:42.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1175}], publishing=[]}} | |
| 2018-06-04T12:23:42,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:23:42.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1235}], publishing=[]}} | |
| 2018-06-04T12:23:42,391 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:23:42.391Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1214}], publishing=[]}} | |
| 2018-06-04T12:23:42,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:23:42.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=2975}], publishing=[]}} | |
| 2018-06-04T12:23:42,556 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:23:42.556Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1213}], publishing=[]}} | |
| 2018-06-04T12:23:42,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:23:42.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1214}], publishing=[]}} | |
| 2018-06-04T12:23:57,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:23:57,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:23:57,409 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:23:57,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:23:57,569 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:23:57,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:24:12,221 INFO [KafkaSupervisor-preprod-credit-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-credit-invocation-history-kafka', generationTime=2018-06-04T12:24:12.221Z, payload={dataSource='preprod-credit-invocation-history-kafka', topic='preprod_CREDIT_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn', startTime=2018-06-04T11:43:17.626Z, remainingSeconds=1145}], publishing=[]}} | |
| 2018-06-04T12:24:12,308 INFO [KafkaSupervisor-preprod-market-decision-result-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-market-decision-result-kafka', generationTime=2018-06-04T12:24:12.308Z, payload={dataSource='preprod-market-decision-result-kafka', topic='preprod_MARKET_DECISION_RESULT_REPORT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj', startTime=2018-06-04T11:44:17.911Z, remainingSeconds=1205}], publishing=[]}} | |
| 2018-06-04T12:24:12,392 INFO [KafkaSupervisor-preprod-payment-event-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-payment-event-plan-repayment-kafka', generationTime=2018-06-04T12:24:12.392Z, payload={dataSource='preprod-payment-event-plan-repayment-kafka', topic='preprod_PAYMENT_EVENT_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch', startTime=2018-06-04T11:43:56.569Z, remainingSeconds=1184}], publishing=[]}} | |
| 2018-06-04T12:24:12,470 INFO [KafkaSupervisor-preprod-risk-invocation-history-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-risk-invocation-history-kafka', generationTime=2018-06-04T12:24:12.470Z, payload={dataSource='preprod-risk-invocation-history-kafka', topic='preprod_RISK_INVOCATION_HISTORY_FLATTEN', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea', startTime=2018-06-04T12:13:18.020Z, remainingSeconds=2945}], publishing=[]}} | |
| 2018-06-04T12:24:12,555 INFO [KafkaSupervisor-preprod-loanend-event-cancel-plan-repayment-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-loanend-event-cancel-plan-repayment-kafka', generationTime=2018-06-04T12:24:12.555Z, payload={dataSource='preprod-loanend-event-cancel-plan-repayment-kafka', topic='preprod_LOANEND_EVENT_CANCEL_PLAN_REPAYMENT', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch', startTime=2018-06-04T11:43:56.542Z, remainingSeconds=1183}], publishing=[]}} | |
| 2018-06-04T12:24:12,622 INFO [KafkaSupervisor-preprod-overdue-event-kafka] io.druid.indexing.kafka.supervisor.KafkaSupervisor - {id='preprod-overdue-event-kafka', generationTime=2018-06-04T12:24:12.622Z, payload={dataSource='preprod-overdue-event-kafka', topic='preprod_OVERDUE_EVENT_SINK', partitions=1, replicas=1, durationSeconds=3600, active=[{id='index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii', startTime=2018-06-04T11:43:56.904Z, remainingSeconds=1184}], publishing=[]}} | |
| 2018-06-04T12:24:27,228 INFO [KafkaIndexTaskClient-preprod-credit-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8105 | |
| 2018-06-04T12:24:27,319 INFO [KafkaIndexTaskClient-preprod-market-decision-result-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8104 | |
| 2018-06-04T12:24:27,410 INFO [KafkaIndexTaskClient-preprod-payment-event-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8100 | |
| 2018-06-04T12:24:27,477 INFO [KafkaIndexTaskClient-preprod-risk-invocation-history-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8103 | |
| 2018-06-04T12:24:27,570 INFO [KafkaIndexTaskClient-preprod-loanend-event-cancel-plan-repayment-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8101 | |
| 2018-06-04T12:24:27,631 INFO [KafkaIndexTaskClient-preprod-overdue-event-kafka-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8102 | |
| 2018-06-04T12:24:32,280 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - Kaboom! Worker[iZuf6flaph02htekc965qjZ:8091] removed! | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found [index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn] running | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found [index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch] running | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found [index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj] running | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found [index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii] running | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found [index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch] running | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] running | |
| 2018-06-04T12:24:32,281 INFO [Curator-PathChildrenCache-0] io.druid.indexing.overlord.RemoteTaskRunner - [iZuf6flaph02htekc965qjZ:8091]: Found 6 tasks assigned | |
| 2018-06-04T12:24:32,307 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle - Running shutdown hook | |
| 2018-06-04T12:24:32,311 INFO [Thread-52] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannouncing [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/overlord', host='iZuf6flaph02htekc965qjZ', port=-1, plaintextPort=8090, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='overlord', services={}}]. | |
| 2018-06-04T12:24:32,311 INFO [Thread-52] io.druid.curator.announcement.Announcer - unannouncing [/druid/internal-discovery/overlord/iZuf6flaph02htekc965qjZ:8090] | |
| 2018-06-04T12:24:32,324 INFO [Thread-52] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/overlord', host='iZuf6flaph02htekc965qjZ', port=-1, plaintextPort=8090, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='overlord', services={}}]. | |
| 2018-06-04T12:24:32,324 INFO [Thread-52] io.druid.server.initialization.jetty.JettyServerModule - Stopping Jetty Server... | |
| 2018-06-04T12:24:32,327 INFO [Thread-52] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@100d0218{HTTP/1.1,[http/1.1]}{0.0.0.0:8090} | |
| 2018-06-04T12:24:32,328 INFO [Thread-52] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@632241f5{/,[jar:file:/usr/local/imply-2.5.11/dist/druid/lib/druid-server-0.12.0-iap10.jar!/static, jar:file:/usr/local/imply-2.5.11/dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar!/indexer_static],UNAVAILABLE} | |
| 2018-06-04T12:24:32,333 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.indexing.overlord.TaskMaster.stop()] on object[io.druid.indexing.overlord.TaskMaster@30abf79c]. | |
| 2018-06-04T12:24:32,336 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.java.util.http.client.NettyHttpClient.stop()] on object[io.druid.java.util.http.client.NettyHttpClient@2bd8f7db]. | |
| 2018-06-04T12:24:32,351 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.indexing.overlord.MetadataTaskStorage.stop()] on object[io.druid.indexing.overlord.MetadataTaskStorage@5c8d58ed]. | |
| 2018-06-04T12:24:32,351 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.storage.hdfs.HdfsStorageAuthentication.stop()] on object[io.druid.storage.hdfs.HdfsStorageAuthentication@691567ea]. | |
| 2018-06-04T12:24:32,351 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.java.util.metrics.MonitorScheduler.stop()] on object[io.druid.java.util.metrics.MonitorScheduler@3b0d3a63]. | |
| 2018-06-04T12:24:32,351 INFO [Thread-52] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.initialization.Log4jShutterDownerModule$Log4jShutterDowner.stop()] on object[io.druid.initialization.Log4jShutterDownerModule$Log4jShutterDowner@6c951ada]. | |
| 2018-06-04 12:24:32,381 Thread-52 ERROR Unable to register shutdown hook because JVM is shutting down. java.lang.IllegalStateException: Not started | |
| at io.druid.common.config.Log4jShutdown.addShutdownCallback(Log4jShutdown.java:47) | |
| at org.apache.logging.log4j.core.impl.Log4jContextFactory.addShutdownCallback(Log4jContextFactory.java:273) | |
| at org.apache.logging.log4j.core.LoggerContext.setUpShutdownHook(LoggerContext.java:256) | |
| at org.apache.logging.log4j.core.LoggerContext.start(LoggerContext.java:216) | |
| at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:145) | |
| at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:41) | |
| at org.apache.logging.log4j.LogManager.getContext(LogManager.java:182) | |
| at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getContext(AbstractLoggerAdapter.java:103) | |
| at org.apache.logging.slf4j.Log4jLoggerFactory.getContext(Log4jLoggerFactory.java:43) | |
| at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getLogger(AbstractLoggerAdapter.java:42) | |
| at org.apache.logging.slf4j.Log4jLoggerFactory.getLogger(Log4jLoggerFactory.java:29) | |
| at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:253) | |
| at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:265) | |
| at org.apache.curator.utils.CloseableUtils.<clinit>(CloseableUtils.java:33) | |
| at org.apache.curator.ConnectionState.close(ConnectionState.java:119) | |
| at org.apache.curator.CuratorZookeeperClient.close(CuratorZookeeperClient.java:227) | |
| at org.apache.curator.framework.imps.CuratorFrameworkImpl.close(CuratorFrameworkImpl.java:381) | |
| at io.druid.curator.CuratorModule$1.stop(CuratorModule.java:98) | |
| at io.druid.java.util.common.lifecycle.Lifecycle.stop(Lifecycle.java:335) | |
| at io.druid.java.util.common.lifecycle.Lifecycle$1.run(Lifecycle.java:366) | |
| at java.lang.Thread.run(Thread.java:748) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment