Feature Request / Improvement
We use a upsert table, then write data with flink batch mode. Of course there is no ck, the insertedRowMap
in BaseTaskWriter.java will be bigger and bigger,and the resource will not be released, so oom might happen.
method: BaseTaskWriter.write
PathOffset previous = insertedRowMap.put(copiedKey, pathOffset);
@openinx@rdblue
any advice can give me?
thanks!
Query engine
Flink