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

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


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

commit 016168d96d69f4b097033de51477810c04ed524e
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat May 24 11:03:03 2025 +0800

    branch-3.0: [fix](mv) refresh failed while open 
enable_single_replica_insert #50986 (#51020)
    
    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