Thanks Vasia, Apologies, yes by workers i mean I have set taskmanager.numberOfTaskSlots: 8 and parallelism.default: 8 in flink-conf.yaml. I have also set taskmanager.heap.mb: 6500
In the dashboard it is showing free memory as 5.64GB and Flink Managed Memory as 3.90GB. Thanks, Rob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Memory-ran-out-error-when-running-connected-components-tp6888p6895.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.