database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[improvement](hive)add the queryid to the temporary file path (#34278) (#34368)

Browse Source 
bp #34278

Co-authored-by: wuwenchi <wuwenchihdu@hotmail.com>
This commit is contained in:
Mingyu Chen
2024-04-30 22:00:05 +08:00
committed by GitHub
parent 8abd136ba2
commit 5fc1f11cf1
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java
View File

@ -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,