This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 5fc1f11cf11 [improvement](hive)add the `queryid` to the temporary file 
path (#34278) (#34368)
5fc1f11cf11 is described below

commit 5fc1f11cf113d6d091c45e3a593466d4abc657ca
Author: Mingyu Chen <morning...@163.com>
AuthorDate: Tue Apr 30 22:00:05 2024 +0800

    [improvement](hive)add the `queryid` to the temporary file path (#34278) 
(#34368)
    
    bp #34278
    
    Co-authored-by: wuwenchi <wuwenchi...@hotmail.com>
---
 .../main/java/org/apache/doris/datasource/hive/HMSTransaction.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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 6fca8b4745f..824af6996a9 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 class HMSTransaction implements Transaction {
             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 class HMSTransaction implements Transaction {
 
             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,


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to