File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/command Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -43,8 +43,9 @@ case class ShowSessionCommand(extended: Boolean = false)
4343 override def run (sparkSession : SparkSession ): Seq [Row ] = {
4444 val sessionId = sparkSession.sparkContext.getLocalProperty(SparkHadoopUtil .HIVE_SESSION_ID )
4545 if (extended) {
46- val application = sparkSession.sqlContext.conf.getConfString(" spark.yarn.app.id" , " " );
47- val queue = sparkSession.sqlContext.conf.getConfString(" spark.yarn.queue" , " " );
46+ val application = System .getProperty(" spark.yarn.app.id" ,
47+ sparkSession.sqlContext.conf.getConfString(" spark.yarn.app.id" , " " ))
48+ val queue = sparkSession.sqlContext.conf.getConfString(" spark.yarn.queue" , " " )
4849 val user = sparkSession.sessionState.catalog.getCurrentUser
4950 Row (" session" , sessionId, " session id" ) ::
5051 Row (" app" , application, " application id" ) ::
You can’t perform that action at this time.
0 commit comments