[
https://issues.apache.org/jira/browse/SPARK-23703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462339#comment-16462339
]
Jungtaek Lim commented on SPARK-23703:
--------------------------------------
[~joseph.torres]
Could you provide simple code or query showing this behavior? It would make me
(and possible other contributors) better understanding of rationalize on this
issue, and maybe relevant internal too.
Once I could understand the details I'd also like to work on this.
> Collapse sequential watermarks
> -------------------------------
>
> Key: SPARK-23703
> URL: https://issues.apache.org/jira/browse/SPARK-23703
> Project: Spark
> Issue Type: Sub-task
> Components: Structured Streaming
> Affects Versions: 2.4.0
> Reporter: Jose Torres
> Priority: Major
>
> When there are two sequential EventTimeWatermark nodes in a query plan, the
> topmost one overrides the column tracking metadata from its children, but
> leaves the nodes themselves untouched. When there is no intervening stateful
> operation to consume the watermark, we should remove the lower node entirely.
--
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
