apache#70, use map to pass properites in PostQueryExecutionForKylin.

Author: Aaaaaaron

sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala

@@ -20,7 +20,6 @@ package org.apache.spark.sql.execution
 import java.util.concurrent.ConcurrentHashMap
 import java.util.concurrent.atomic.AtomicLong
 
-import org.apache.spark.MapOutputTrackerMaster
 import org.apache.spark.SparkEnv
 import org.apache.spark.internal.Logging
 import org.apache.spark.sql.SparkSession
@@ -81,7 +80,8 @@ object SQLExecution extends Logging{
           SparkPlanInfo.fromSparkPlan(queryExecution.executedPlan), System.currentTimeMillis()))
 
         sc.listenerBus.post(PostQueryExecutionForKylin(
-          sc.getLocalProperty(N_EXECUTION_ID_KEY),
+          sc.getLocalProperties,
+          executionId,
           queryExecution))
         try {
           body

sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala

@@ -17,6 +17,8 @@
 
 package org.apache.spark.sql.execution.ui
 
+import java.util.Properties
+
 import com.fasterxml.jackson.databind.JavaType
 import com.fasterxml.jackson.databind.`type`.TypeFactory
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize
@@ -38,7 +40,8 @@ case class SparkListenerSQLExecutionStart(
 
 @DeveloperApi
 case class PostQueryExecutionForKylin(
-    nExecutionId: String = "",
+    localProperties: Properties,
+    executionId: Long,
     queryExecution: QueryExecution = null)
   extends SparkListenerEvent {