Replace getUserFromAuthenticator because it is introduced in 0.13.

dongjoon-hyun · dongjoon-hyun · commit e8ef7d115ec3 · 2017-03-16T03:55:32.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(SessionState.getUserFromAuthenticator()))
+    conf.foreach(c => hiveTable.setOwner(SessionState.get().getAuthenticator().getUserName()))
     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(SessionState.getUserFromAuthenticator()))`
	`854`	`+ conf.foreach(c => hiveTable.setOwner(SessionState.get().getAuthenticator().getUserName()))`
`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 =>`