From fc2588c7866fdcae2414546d1b76f6b3f03ac070 Mon Sep 17 00:00:00 2001
From: slothever <18522955+wsjz@users.noreply.github.com>
Date: Tue, 19 Mar 2024 16:04:09 +0800
Subject: [PATCH] [fix](insert)fix sink user name (#32465)

---
 .../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 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("-", "");
     }