Hi Robert, I had resolved this issue earlier as I had not set the Kafka source parallelism to number of partitions, so I was getting the issue of window not getting triggered.
Now I am facing the same issue, I tried to check the watermark value by using visualVM locally but I am not seeing that value there, I have attached the snapahot of visualVM <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n10412/jVisualVMMetrics.png> Just to verify , JMX port runs on 9010 by default , right ?, because when I tried to connect to it locally, I could not connect -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dealing-with-Multiple-sinks-in-Flink-tp8643p10412.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
