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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
