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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
