Hi, Could you maybe give an example of what you expect as output and what you actually get?
Best, Aljoscha > On 9. Oct 2017, at 16:09, mclendenin <marcusc...@gmail.com> wrote: > > I am using Processing Time, so it is using the default timestamps and > watermarks. I am running it with a parallelism of 3, I can see each operator > running at a parallelism of 3 on the Web UI. I am pulling data from a Kafka > topic with 12 partitions. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
