[
https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2789:
Affects Version/s: (was: 2.0.0)
> Watermark can become unavailable for executors while it's updated with
[
https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stas Levin updated BEAM-2789:
-
Summary: Watermark can become unavailable for executors while it's updated
with new values (was: Watermark
[
https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stas Levin updated BEAM-2789:
-
Description:
The watermark is updated by the driver like so:
{code:java}
blockManager.removeBlock(WATERMAR
