Hi, Sharing new findings. The issue I have mentioned above seems to be happening only with the latest version of EMR(emr-5.20.0, hadoop: Amazon 2.8.5, Flink: 1.6.2) and it is reproducible with our setup every time. I have verified the same setup working and scaling without any issues on an older EMR version(emr-5.16.0, hadoop: Amazon 2.8.4, Flink: 1.5.0).
Hope the above details help in resolving the issue and help others facing this issue. Regards, Suraj -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/