[fix](chore) fix session var memtable on sink for bulk load (#29102)

2023-12-29 17:00:02 +08:00
parent 1a2ec2fbd9
commit ada5cf4b2e
1 changed files with 1 additions and 0 deletions
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java
@ -154,6 +154,7 @@ public class LoadLoadingTask extends LoadTask {
         * here we use exec_mem_limit to directly override the load_mem_limit property.
         */
        curCoordinator.setLoadMemLimit(execMemLimit);
+        curCoordinator.setMemTableOnSinkNode(enableMemTableOnSinkNode);

        long leftTimeMs = getLeftTimeMs();
        if (leftTimeMs <= 0) {