2018-06-26 15:21:41.602 [marshalled-with-bot-header-for-dev -> Sink: kafka-sink-for-dev (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,odin-router-v2,marshalled-with-bot-header-for-dev -> Sink: kafka-sink-for-dev,0,buffers and metric group variables {<job_id>=58f009823d425ec30a95fcab9b91929f, <task_id>=cc2765d0460902a818200cb341f809c2, <task_attempt_id>=d00c5dc5565d99849c4d996057cdf99f, <host>=flinkworker001, <task_name>=marshalled-with-bot-header-for-dev -> Sink: kafka-sink-for-dev, <task_attempt_num>=0, <job_name>=odin-router-v2, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 0
2018-06-26 15:21:41.605 [bots-for-dev -> Map -> Sink: bots-sink-for-dev (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,odin-router-v2,bots-for-dev -> Map -> Sink: bots-sink-for-dev,0,buffers and metric group variables {<job_id>=58f009823d425ec30a95fcab9b91929f, <task_id>=83df09636bb350560b5f98563cc74f57, <task_attempt_id>=ffa5f9398bde80c4e85d12038cdb9b69, <host>=flinkworker001, <task_name>=bots-for-dev -> Map -> Sink: bots-sink-for-dev, <task_attempt_num>=0, <job_name>=odin-router-v2, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 1
2018-06-26 15:21:41.612 [Source: kafka-source-for-dev -> marshalling-for-dev -> (Flat Map, pii-and-nonpii-for-dev) (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,odin-router-v2,Source: kafka-source-for-dev -> marshalling-for-dev -> (Flat Map, pii-and-nonpii-for-dev),0,buffers and metric group variables {<job_id>=58f009823d425ec30a95fcab9b91929f, <task_id>=e88427a3f2292fd83a881281ca32e317, <task_attempt_id>=19880799af3abd1ddd396aac1f2e4f4e, <host>=flinkworker001, <task_name>=Source: kafka-source-for-dev -> marshalling-for-dev -> (Flat Map, pii-and-nonpii-for-dev), <task_attempt_num>=0, <job_name>=odin-router-v2, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 2
2018-06-26 15:23:20.502 [Source: kafka-source-reaction-views -> filtered-views -> views (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,Source: kafka-source-reaction-views -> filtered-views -> views,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=590884759e085b7988e6295889a2fffe, <task_attempt_id>=0de7367b4b0415b7c8c79bb73fe429b3, <host>=flinkworker001, <task_name>=Source: kafka-source-reaction-views -> filtered-views -> views, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 3
2018-06-26 15:23:20.507 [Source: kafka-source-ad-deletes -> cleanup-queue-items (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,Source: kafka-source-ad-deletes -> cleanup-queue-items,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=8daabebbb8d55449bdc9d59d2d0e3677, <task_attempt_id>=6f6bdbbc9f6e88c71f792e6cfaa4b579, <host>=flinkworker001, <task_name>=Source: kafka-source-ad-deletes -> cleanup-queue-items, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 4
2018-06-26 15:23:20.511 [buffered-unique-views-per-day -> Sink: cassandra-sink (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,buffered-unique-views-per-day -> Sink: cassandra-sink,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=59fde8bd4b4482cfb22134e20521abd9, <task_attempt_id>=0eb245932abda4866c85d7d06da71f3c, <host>=flinkworker001, <task_name>=buffered-unique-views-per-day -> Sink: cassandra-sink, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 5
2018-06-26 15:23:20.513 [unique-views-per-day -> Map -> Sink: late-views (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,unique-views-per-day -> Map -> Sink: late-views,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=04c3abd3d7d44bb11ea475260ffec7a2, <task_attempt_id>=d29bc78d9a3bfe6bba7fa44071daf780, <host>=flinkworker001, <task_name>=unique-views-per-day -> Map -> Sink: late-views, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 6
2018-06-26 15:23:20.515 [delayed-cleanup-queue-items -> Map -> Sink: delete-counters-cassandra-sink (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric added with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,delayed-cleanup-queue-items -> Map -> Sink: delete-counters-cassandra-sink,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=627d91b17d0d23202e3f0f00f27e584b, <task_attempt_id>=2347d3b9b2f4174dae124b2a7c8a759b, <host>=flinkworker001, <task_name>=delayed-cleanup-queue-items -> Map -> Sink: delete-counters-cassandra-sink, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 7
2018-06-26 15:27:35.337 [buffered-unique-views-per-day -> Sink: cassandra-sink (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric removed with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,buffered-unique-views-per-day -> Sink: cassandra-sink,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=59fde8bd4b4482cfb22134e20521abd9, <task_attempt_id>=0eb245932abda4866c85d7d06da71f3c, <host>=flinkworker001, <task_name>=buffered-unique-views-per-day -> Sink: cassandra-sink, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 8
2018-06-26 15:27:35.344 [delayed-cleanup-queue-items -> Map -> Sink: delete-counters-cassandra-sink (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric removed with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,delayed-cleanup-queue-items -> Map -> Sink: delete-counters-cassandra-sink,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=627d91b17d0d23202e3f0f00f27e584b, <task_attempt_id>=2347d3b9b2f4174dae124b2a7c8a759b, <host>=flinkworker001, <task_name>=delayed-cleanup-queue-items -> Map -> Sink: delete-counters-cassandra-sink, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 7
2018-06-26 15:27:35.356 [unique-views-per-day -> Map -> Sink: late-views (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric removed with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,unique-views-per-day -> Map -> Sink: late-views,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=04c3abd3d7d44bb11ea475260ffec7a2, <task_attempt_id>=d29bc78d9a3bfe6bba7fa44071daf780, <host>=flinkworker001, <task_name>=unique-views-per-day -> Map -> Sink: late-views, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 6
2018-06-26 15:27:35.361 [Source: kafka-source-ad-deletes -> cleanup-queue-items (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric removed with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,Source: kafka-source-ad-deletes -> cleanup-queue-items,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=8daabebbb8d55449bdc9d59d2d0e3677, <task_attempt_id>=6f6bdbbc9f6e88c71f792e6cfaa4b579, <host>=flinkworker001, <task_name>=Source: kafka-source-ad-deletes -> cleanup-queue-items, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 5
2018-06-26 15:27:35.366 [Source: kafka-source-reaction-views -> filtered-views -> views (1/1)] INFO  org.apache.flink.metrics.prometheus.PrometheusReporter  - Metric removed with metricName inputQueueLength and scopedMetricName flink_taskmanager_job_task_buffers_inputQueueLength and metricGroup scope components flinkworker001,taskmanager,mim-advertisement-counters-flink-v2-cdata,Source: kafka-source-reaction-views -> filtered-views -> views,0,buffers and metric group variables {<job_id>=be6b25487ae34283fbe64b4ad0cb1fa9, <task_id>=590884759e085b7988e6295889a2fffe, <task_attempt_id>=0de7367b4b0415b7c8c79bb73fe429b3, <host>=flinkworker001, <task_name>=Source: kafka-source-reaction-views -> filtered-views -> views, <task_attempt_num>=0, <job_name>=mim-advertisement-counters-flink-v2-cdata, <tm_id>=9fce323ec41b9537e85d6ed52c38cdb2, <subtask_index>=0}. Count is 4