|
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 .
|