From 6c726dd6f43192e0e264d75807d354746c95f2a4 Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Mon, 20 Mar 2017 14:28:33 -0700 Subject: [PATCH] [SPARK-19970][SQL][BRANCH-1.6] Table owner should be USER instead of PRINCIPAL in kerberized clusters --- .../scala/org/apache/spark/sql/hive/client/ClientWrapper.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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])