Update HiveClientImpl.scala

hddong · web-flow · commit a8d6b1d69b7c · 2019-09-11T09:26:24.000+08: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
@@ -221,18 +221,14 @@ private[hive] class HiveClientImpl(
     hiveConf
   }
 
-  private val userName = try {
+  private val userName = {
     val doAs = sys.env.get("HADOOP_USER_NAME").orNull
     val ugi = if (doAs != null && doAs.length() > 0) {
       UserGroupInformation.createProxyUser(doAs, UserGroupInformation.getLoginUser())
     } else {
       UserGroupInformation.getCurrentUser
     }
     ugi.getShortUserName
-  } catch {
-    case e: Exception =>
-      logError("Can not get login user.")
-      throw e
   }
 
   override def getConf(key: String, defaultValue: String): String = {

Original file line number	Diff line number	Diff line change
`@@ -221,18 +221,14 @@ private[hive] class HiveClientImpl(`
`221`	`221`	`hiveConf`
`222`	`222`	`}`
`223`	`223`
`224`		`- private val userName = try {`
	`224`	`+ private val userName = {`
`225`	`225`	`val doAs = sys.env.get("HADOOP_USER_NAME").orNull`
`226`	`226`	`val ugi = if (doAs != null && doAs.length() > 0) {`
`227`	`227`	`UserGroupInformation.createProxyUser(doAs, UserGroupInformation.getLoginUser())`
`228`	`228`	`} else {`
`229`	`229`	`UserGroupInformation.getCurrentUser`
`230`	`230`	`}`
`231`	`231`	`ugi.getShortUserName`
`232`		`- } catch {`
`233`		`- case e: Exception =>`
`234`		`- logError("Can not get login user.")`
`235`		`- throw e`
`236`	`232`	`}`
`237`	`233`
`238`	`234`	`override def getConf(key: String, defaultValue: String): String = {`