You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2025/05/24 03:03:10 UTC

(doris) branch branch-3.0 updated: branch-3.0: [fix](mv) refresh failed while open enable_single_replica_insert #50986 (#51020)

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] <41...@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 <ca...@tencent.com>
---
 .../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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org