This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 fc2588c7866 [fix](insert)fix sink user name (#32465)
fc2588c7866 is described below
commit fc2588c7866fdcae2414546d1b76f6b3f03ac070
Author: slothever <18522955+w...@users.noreply.github.com>
AuthorDate: Tue Mar 19 16:04:09 2024 +0800
[fix](insert)fix sink user name (#32465)
---
fe/fe-core/src/main/java/org/apache/doris/planner/HiveTableSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/HiveTableSink.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/HiveTableSink.java
index 5dce86b3330..4652c132a9e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/HiveTableSink.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/HiveTableSink.java
@@ -152,7 +152,7 @@ public class HiveTableSink extends DataSink {
}
private String createTempPath(String location) {
- String user = ConnectContext.get().getUserIdentity().getUser();
+ String user =
ConnectContext.get().getUserIdentity().getQualifiedUser();
return location + "/.doris_staging/" + user + "/" +
UUID.randomUUID().toString().replace("-", "");
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
