change self

apache · May 16, 2016 · e756a0a · e756a0a
1 parent 3b5eb9b
commit e756a0a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala
@@ -110,7 +110,7 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) {
    */
   def hiveResultString(): Seq[String] = executedPlan match {
     case ExecutedCommandExec(desc: DescribeTableCommand) =>
-      SQLExecution.withNewExecutionId(self, this) {
+      SQLExecution.withNewExecutionId(sparkSession, this) {
         // If it is a describe command for a Hive table, we want to have the output format
         // be similar with Hive.
         desc.run(sparkSession).map {
@@ -122,11 +122,11 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) {
         }
       }
     case command: ExecutedCommandExec =>
-      SQLExecution.withNewExecutionId(self, this) {
+      SQLExecution.withNewExecutionId(sparkSession, this) {
         command.executeCollect().map(_.getString(0))
       }
     case other =>
-      SQLExecution.withNewExecutionId(self, this) {
+      SQLExecution.withNewExecutionId(sparkSession, this) {
         val result: Seq[Seq[Any]] = other.executeCollectPublic().map(_.toSeq).toSeq
         // We need the types so we can output struct field names
         val types = analyzed.output.map(_.dataType)