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 6fca8b4745feb9..824af6996a97bb 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 @@ -1187,7 +1187,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, @@ -1342,7 +1343,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,