This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 949ddbc3d62 branch-3.1: [log](insert-overwrite) Add log for insert
overwrite auto detect begin #57418 (#57444)
949ddbc3d62 is described below
commit 949ddbc3d62ff71c19a1548bc993870d132a2953
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Nov 3 11:26:02 2025 +0800
branch-3.1: [log](insert-overwrite) Add log for insert overwrite auto
detect begin #57418 (#57444)
Cherry-picked from #57418
Co-authored-by: zclllyybb <[email protected]>
---
.../java/org/apache/doris/insertoverwrite/InsertOverwriteManager.java | 4 +++-
.../trees/plans/commands/insert/InsertOverwriteTableCommand.java | 2 +-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteManager.java
b/fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteManager.java
index cb01ff90339..a5e3dec4296 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteManager.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteManager.java
@@ -103,11 +103,13 @@ public class InsertOverwriteManager extends MasterDaemon
implements Writable {
*
* @return group id, like a transaction id.
*/
- public long registerTaskGroup() {
+ public long registerTaskGroup(long tableId) {
long groupId = Env.getCurrentEnv().getNextId();
taskGroups.put(groupId, new ArrayList<Long>());
taskLocks.put(groupId, new ReentrantLock());
partitionPairs.put(groupId, Maps.newConcurrentMap());
+ LOG.info("registered insert overwrite auto detect partition task group
[" + groupId + "] for table "
+ + tableId);
return groupId;
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertOverwriteTableCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertOverwriteTableCommand.java
index 0ad5a55e879..49fb60483c3 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertOverwriteTableCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertOverwriteTableCommand.java
@@ -202,7 +202,7 @@ public class InsertOverwriteTableCommand extends Command
implements ForwardWithS
try {
if (isAutoDetectOverwrite(getLogicalQuery())) {
// taskId here is a group id. it contains all replace tasks
made and registered in rpc process.
- taskId = insertOverwriteManager.registerTaskGroup();
+ taskId =
insertOverwriteManager.registerTaskGroup(targetTable.getId());
// When inserting, BE will call to replace partition by
FrontendService. FE will register new temp
// partitions and return. for transactional, the replacement
will really occur when insert successed,
// i.e. `insertInto` finished. then we call taskGroupSuccess
to make replacement.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
