Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/21400
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
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
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21400#discussion_r191278428
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala
---
@@ -34,7 +34,8 @@ class ContinuousSuiteBase
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21400#discussion_r191278390
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala
---
@@ -225,6 +226,40 @@ class ContinuousSuite
GitHub user ivoson opened a pull request:
https://github.com/apache/spark/pull/21400
[SPARK-24351][SS]offsetLog/commitLog purge thresholdBatchId should be
computed with cuâ¦
## What changes were proposed in this pull request?
Compute the thresholdBatchId to purge metadata
