Is it possible that the data is dropped due to being late, i.e., records with timestamps behind the current watemark? What kind of operations does your program consist of?
Best, Fabian 2017-12-07 10:20 GMT+01:00 Sendoh <unicorn.bana...@gmail.com>: > 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/ >
