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/
