flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nishant Gupta <nishantgupta1...@gmail.com>
Subject Flink- Heap Space running out
Date Thu, 26 Sep 2019 14:14:23 GMT
 am running a query to join a stream and a table as below. It is running
out of heap space. Even though it has enough heap space in flink cluster
(60GB * 3)

Is there an eviction strategy needed for this query ?

*SELECT sourceKafka.* FROM sourceKafka INNER JOIN DefaulterTable ON
sourceKafka.CC=DefaulterTable.CC;  *

Thanks

Nishant

Mime
View raw message