You can configure the task manager memory in the config.yaml file. What is the current configuration?
On Thu, Sep 26, 2019, 17:14 Nishant Gupta <nishantgupta1...@gmail.com> wrote: > 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 >
