[jira] [Created] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2019-12-27 Thread Benchao Li (Jira)
Benchao Li created FLINK-15431: -- Summary: Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator Key: FLINK-15431 URL: https://issues.apache.org/jira/browse/FLINK-15431 Project

numLateRecordsDropped

2019-01-29 Thread Ramya Ramamurthy
Hi, I am reading from Kafka and pushing it to the ES. There are basically 2 operators that we have, one to consume from Kafka and the other does the operation on the Flink table and pushes to ES. [image: image.png] I am able to see the Flink Metrics : numLateRecordsDropped on my second operator