diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala
index f446f12a82d2f..4a4385c913634 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala
@@ -376,7 +376,7 @@ private[hive] class ClientWrapper(
     table.serdeProperties.foreach { case (k, v) => qlTable.setSerdeParam(k, v) }
 
     // set owner
-    qlTable.setOwner(conf.getUser)
+    qlTable.setOwner(state.getAuthenticator().getUserName())
     // set create time
     qlTable.setCreateTime((System.currentTimeMillis() / 1000).asInstanceOf[Int])