[SPARK-19970][SQL] Table owner should be USER instead of PRINCIPAL in kerberized clusters

dongjoon-hyun · dongjoon-hyun · commit 9dfbf828be5f · 2017-03-16T02:12:37.000-07:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
@@ -851,7 +851,7 @@ private[hive] object HiveClientImpl {
       hiveTable.setFields(schema.asJava)
     }
     hiveTable.setPartCols(partCols.asJava)
-    conf.foreach(c => hiveTable.setOwner(c.getUser))
+    conf.foreach(c => hiveTable.setOwner(SessionState.getUserFromAuthenticator()))
     hiveTable.setCreateTime((table.createTime / 1000).toInt)
     hiveTable.setLastAccessTime((table.lastAccessTime / 1000).toInt)
     table.storage.locationUri.map(CatalogUtils.URIToString(_)).foreach { loc =>

Original file line number	Diff line number	Diff line change
`@@ -851,7 +851,7 @@ private[hive] object HiveClientImpl {`
`851`	`851`	`hiveTable.setFields(schema.asJava)`
`852`	`852`	`}`
`853`	`853`	`hiveTable.setPartCols(partCols.asJava)`
`854`		`- conf.foreach(c => hiveTable.setOwner(c.getUser))`
	`854`	`+ conf.foreach(c => hiveTable.setOwner(SessionState.getUserFromAuthenticator()))`
`855`	`855`	`hiveTable.setCreateTime((table.createTime / 1000).toInt)`
`856`	`856`	`hiveTable.setLastAccessTime((table.lastAccessTime / 1000).toInt)`
`857`	`857`	`table.storage.locationUri.map(CatalogUtils.URIToString(_)).foreach { loc =>`