Github user aray commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r143345713
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -562,6 +563,8 @@ class SparkContext(config: SparkConf) extends Logging {
}
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r136516938
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -562,6 +563,8 @@ class SparkContext(config: SparkConf) extends Logging {
Github user aray commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r136436631
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -562,6 +563,8 @@ class SparkContext(config: SparkConf) extends Logging {
}
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r136410312
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -562,6 +563,8 @@ class SparkContext(config: SparkConf) extends Logging {
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r122122675
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryManagerSuite.scala
---
@@ -239,6 +237,40 @@ class StreamingQueryManagerS
Github user aray commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r122112073
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
---
@@ -690,6 +690,7 @@ class SparkSession private(
* @since 2.0.0
*/
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r122092151
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
---
@@ -690,6 +690,7 @@ class SparkSession private(
* @since 2.0.0
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/18306#discussion_r122091309
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala
---
@@ -321,6 +321,17 @@ class StreamingQueryManager private[s
GitHub user aray opened a pull request:
https://github.com/apache/spark/pull/18306
[SPARK-21029][SS] All StreamingQuery should be stopped when the
SparkSession is stopped
## What changes were proposed in this pull request?
Adds method to `StreamingQueryManager` that stops a
