flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mclendenin <marcusc...@gmail.com>
Subject Re: Windowing isn't applied per key
Date Mon, 09 Oct 2017 14:09:28 GMT
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/

View raw message