All accumulators/ counters which are set to Kfka Source or Kafka Sink are missing after upgrading to Flink Kafka 0.10 ?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

All accumulators/ counters which are set to Kfka Source or Kafka Sink are missing after upgrading to Flink Kafka 0.10 ?

sohimankotia
I was using Flink Kafka 08 api for consuming and producing to Kafka .

Yesterday I upgraded to flink 1.2 and started using Flink Kafka 0.10 api for consumer and producer .

Issue I found is , all accumulators that I have added to source or sink are appearing in flink web api , which were there before upgrading to 0.10 .