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

Reply via email to