-
- Downloads
[SPARK-20048][SQL] Cloning SessionState does not clone query execution listeners
## What changes were proposed in this pull request? Bugfix from [SPARK-19540.](https://github.com/apache/spark/pull/16826) Cloning SessionState does not clone query execution listeners, so cloned session is unable to listen to events on queries. ## How was this patch tested? - Unit test Author: Kunal Khamar <kkhamar@outlook.com> Closes #17379 from kunalkhamar/clone-bugfix.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala 11 additions, 11 deletions...re/src/main/scala/org/apache/spark/sql/SparkSession.scala
- sql/core/src/main/scala/org/apache/spark/sql/internal/BaseSessionStateBuilder.scala 22 additions, 2 deletions...g/apache/spark/sql/internal/BaseSessionStateBuilder.scala
- sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala 11 additions, 27 deletions...in/scala/org/apache/spark/sql/internal/SessionState.scala
- sql/core/src/main/scala/org/apache/spark/sql/util/QueryExecutionListener.scala 10 additions, 0 deletions...la/org/apache/spark/sql/util/QueryExecutionListener.scala
- sql/core/src/test/scala/org/apache/spark/sql/SessionStateSuite.scala 53 additions, 0 deletions...c/test/scala/org/apache/spark/sql/SessionStateSuite.scala
- sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala 1 addition, 1 deletion...pache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala 1 addition, 13 deletions...a/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/test/TestHive.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/sql/hive/test/TestHive.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveSessionStateSuite.scala 1 addition, 1 deletion...ala/org/apache/spark/sql/hive/HiveSessionStateSuite.scala
Loading
Please register or sign in to comment