This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new d63815fa574 branch-2.1: [fix](mv) refresh failed while open 
enable_single_replica_insert #50986 (#51021)
d63815fa574 is described below

commit d63815fa574f27431846b0ba74116d347d613838
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed May 21 12:07:48 2025 +0800

    branch-2.1: [fix](mv) refresh failed while open 
enable_single_replica_insert #50986 (#51021)
    
    Cherry-picked from #50986
    
    Co-authored-by: camby <[email protected]>
---
 .../implementation/LogicalOlapTableSinkToPhysicalOlapTableSink.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalOlapTableSinkToPhysicalOlapTableSink.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalOlapTableSinkToPhysicalOlapTableSink.java
index 37fefecb9e5..d88ce20bb59 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalOlapTableSinkToPhysicalOlapTableSink.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalOlapTableSinkToPhysicalOlapTableSink.java
@@ -39,7 +39,8 @@ public class LogicalOlapTableSinkToPhysicalOlapTableSink 
extends OneImplementati
                     sink.getCols(),
                     sink.getPartitionIds(),
                     sink.getOutputExprs(),
-                    
ctx.connectContext.getSessionVariable().isEnableSingleReplicaInsert(),
+                    
ctx.connectContext.getSessionVariable().isEnableMemtableOnSinkNode() ? false
+                            : 
ctx.connectContext.getSessionVariable().isEnableSingleReplicaInsert(),
                     sink.isPartialUpdate(),
                     sink.getDmlCommandType(),
                     Optional.empty(),


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to