(doris) branch master updated: [fix](Nereids) insert into target table lock should include finalize (#28085)

[morrysnow]

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

morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new f37215a32a2 [fix](Nereids) insert into target table lock should 
include finalize (#28085)
f37215a32a2 is described below

commit f37215a32a2a6050333778082c9da4db8a27d9bd
Author: morrySnow <101034200+morrys...@users.noreply.github.com>
AuthorDate: Thu Dec 7 20:15:12 2023 +0800

    [fix](Nereids) insert into target table lock should include finalize 
(#28085)
---
 .../doris/nereids/trees/plans/commands/InsertIntoTableCommand.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/InsertIntoTableCommand.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/InsertIntoTableCommand.java
index c17f215e757..213ec4df3ce 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/InsertIntoTableCommand.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/InsertIntoTableCommand.java
@@ -155,12 +155,12 @@ public class InsertIntoTableCommand extends Command 
implements ForwardWithSync,
                     physicalOlapTableSink.getDatabase(),
                     physicalOlapTableSink.getTargetTable(), label, planner);
             insertExecutor.beginTransaction();
+            insertExecutor.finalizeSink(sink, 
physicalOlapTableSink.isPartialUpdate(),
+                    physicalOlapTableSink.isFromNativeInsertStmt());
         } finally {
             targetTableIf.readUnlock();
         }
 
-        insertExecutor.finalizeSink(sink, 
physicalOlapTableSink.isPartialUpdate(),
-                physicalOlapTableSink.isFromNativeInsertStmt());
         executor.setProfileType(ProfileType.LOAD);
         // We exposed @StmtExecutor#cancel as a unified entry point for 
statement interruption
         // so we need to set this here


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org