diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java index 32dd083c2adaf5..27f7737985be48 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java @@ -1109,7 +1109,8 @@ public void prepareAlterTable(TableAndMore tableAndMore) { String writePath = tableAndMore.getCurrentLocation(); if (!targetPath.equals(writePath)) { Path path = new Path(targetPath); - String oldTablePath = new Path(path.getParent(), "_temp_" + path.getName()).toString(); + String oldTablePath = new Path( + path.getParent(), "_temp_" + queryId + "_" + path.getName()).toString(); Status status = wrapperRenameDirWithProfileSummary( targetPath, oldTablePath, @@ -1242,7 +1243,8 @@ public void prepareAlterPartition(PartitionAndMore partitionAndMore) { if (!targetPath.equals(writePath)) { Path path = new Path(targetPath); - String oldPartitionPath = new Path(path.getParent(), "_temp_" + path.getName()).toString(); + String oldPartitionPath = new Path( + path.getParent(), "_temp_" + queryId + "_" + path.getName()).toString(); Status status = wrapperRenameDirWithProfileSummary( targetPath, oldPartitionPath,