Github user efimpoberezkin closed the pull request at:
https://github.com/apache/spark/pull/21392
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache
Github user efimpoberezkin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190473131
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -45,6 +45,11 @@ private[sql] cas
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190316039
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -45,6 +45,11 @@ private[sql] case o
Github user efimpoberezkin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190160821
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -45,6 +45,11 @@ private[sql] cas
Github user efimpoberezkin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190158513
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -153,9 +161,13 @@ private[contin
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190112873
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala
---
@@ -233,9 +235,15 @@ class Continuo
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190112179
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -45,6 +45,11 @@ private[sql] case o
Github user yanlin-Lynn commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190109933
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala
---
@@ -153,9 +161,13 @@ private[continuou
Github user yanlin-Lynn commented on a diff in the pull request:
https://github.com/apache/spark/pull/21392#discussion_r190108352
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala
---
@@ -233,9 +235,15 @@ class Continuo
GitHub user efimpoberezkin opened a pull request:
https://github.com/apache/spark/pull/21392
[SPARK-24063][SS] Control maximum epoch backlog for ContinuousExecution
## What changes were proposed in this pull request?
This pull request adds maxEpochBacklog SQL configuration o
10 matches
Mail list logo