Hi, I am getting Java Heap Space error while running Flink Job (Flink 1.2 ) .
Use case : I am getting all keys from REDIS with specific pattern . Then streaming over those keys and reading data from Redis for those key and writing to file in HDFS . Job was running fine for few days but suddenly started giving Heap Space error . Job Parallelism : 9 ( 3 nodes and 3 slots) Total Redis Keys : 1031966 ( aprox 33 MB in size (keys only)) Logs : -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/