Github user ivoson commented on a diff in the pull request:
https://github.com/apache/spark/pull/21400#discussion_r191980682
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala
---
@@ -34,7 +34,8 @@ class ContinuousSuiteBase extends StreamTest {
new SparkContext(
"local[10]",
"continuous-stream-test-sql-context",
- sparkConf.set("spark.sql.testkey", "true")))
+ sparkConf.set("spark.sql.testkey", "true")
+ .set("spark.sql.streaming.minBatchesToRetain", "2")))
--- End diff --
@jose-torres Thanks for pointing this out. I will make a separate suite for
clarity and isolation.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
