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 5dce86b333..4652c132a9 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("-", ""); }