I would recommend to also print the count of input and output of each operator by using Accumulator.
Cheers, Sendoh -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
- Data loss in Flink Kafka Pipeline Nishu
- Re: Data loss in Flink Kafka Pipeline Sendoh
- Re: Data loss in Flink Kafka Pipeline Fabian Hueske
- Re: Data loss in Flink Kafka Pipeline Chen Qin
- Re: Data loss in Flink Kafka Pipeline Nishu
- Re: Data loss in Flink Kafka Pipeli... Fabian Hueske
- Re: Data loss in Flink Kafka Pi... Nishu
- Re: Data loss in Flink Kafk... Fabian Hueske
- Re: Data loss in Flink Kafk... Aljoscha Krettek
- Re: Data loss in Flink Kafka Pipeline Nishu
