You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2024/04/30 13:23:00 UTC
(doris) branch master updated: [improvement](hive)add the `queryid` to the temporary file path (#34278)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 3656bd3221a [improvement](hive)add the `queryid` to the temporary file path (#34278)
3656bd3221a is described below
commit 3656bd3221a1c15e7568d280e6b48a92bcf4bc2a
Author: wuwenchi <wu...@hotmail.com>
AuthorDate: Tue Apr 30 21:22:52 2024 +0800
[improvement](hive)add the `queryid` to the temporary file path (#34278)
`_temp_<table_name>` to `_temp_<queryid>_<table_name>`.
Prevent users from having a table with the name `_temp_<table_name>`.
So as to partition temp dir
---
.../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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org