Hi, I have a simple job where FlinkKafkaConsumer08 reads data from a topic (with 8 partitions) and a custom Sink implementation inserts the data into Accumulo database. I can verify that the data is getting inserted into the db by adding simple system.out.println(...) to the invoke method of the sink and also monitoring Accumulo stats. However Flink Web Dashboard reports 0 for sent/received bytes and records (see attached file for a snapshot). Any thoughts?
*Hadoop platform*: Hortonworks Data Platform 2.5 *Flink*: flink-1.2.0-bin-hadoop27-scala_2.10 Thanks, Mohammad
