[
https://issues.apache.org/jira/browse/SPARK-27413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apache Spark reassigned SPARK-27413:
------------------------------------
Assignee: (was: Apache Spark)
> Keep the same epoch pace between driver and executor.
> -----------------------------------------------------
>
> Key: SPARK-27413
> URL: https://issues.apache.org/jira/browse/SPARK-27413
> Project: Spark
> Issue Type: Improvement
> Components: Structured Streaming
> Affects Versions: 3.0.0
> Reporter: Genmao Yu
> Priority: Minor
>
> The pace of epoch generation in driver and epoch pulling in executor is
> different. It will result in many empty epochs for partition if the epoch
> pulling interval is larger than epoch generation.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
