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 d774a06b720 [fix](Nereids) not release lock if schema changed when
insert (#47733)
d774a06b720 is described below
commit d774a06b7204f8508a9ab96343ca0ca0f4e2864b
Author: morrySnow <zhangwen...@selectdb.com>
AuthorDate: Wed Feb 12 17:40:19 2025 +0800
[fix](Nereids) not release lock if schema changed when insert (#47733)
---
.../nereids/trees/plans/commands/insert/InsertIntoTableCommand.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
index 39c5909d4f5..cba3373a6c2 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
@@ -190,6 +190,7 @@ public class InsertIntoTableCommand extends Command
implements ForwardWithSync,
LOG.warn("insert plan failed {} times. query id is {}.
table id changed from {} to {}",
retryTimes, DebugUtil.printId(ctx.queryId()),
targetTableIf.getId(),
newestTargetTableIf.getId());
+ newestTargetTableIf.readUnlock();
continue;
}
// Use the schema saved during planning as the schema of the
original target table.
@@ -197,6 +198,7 @@ public class InsertIntoTableCommand extends Command
implements ForwardWithSync,
LOG.warn("insert plan failed {} times. query id is {}.
table schema changed from {} to {}",
retryTimes, DebugUtil.printId(ctx.queryId()),
ctx.getStatementContext().getInsertTargetSchema(),
newestTargetTableIf.getFullSchema());
+ newestTargetTableIf.readUnlock();
continue;
}
if (!insertExecutor.isEmptyInsert()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
