Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20936#discussion_r183492587
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -137,30 +137,65 @@ private[continuous]
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/20936#discussion_r182571570
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -137,30 +137,65 @@
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/20936#discussion_r178116898
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -145,18 +149,42 @@
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/20936#discussion_r178116567
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -145,18 +149,42 @@
GitHub user efimpoberezkin opened a pull request:
https://github.com/apache/spark/pull/20936
[SPARK-23503][Structured Streaming] Enforcing sequencing of committed
epochs for Continuous Execution
## What changes were proposed in this pull request?
Made changes to
