Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
None
-
None
Description
The timestamp should lie in the window, otherwise re-windowing will not be idempotent.
https://github.com/apache/beam/blob/release-2.16.0/sdks/python/apache_beam/transforms/trigger.py#L1183 should be using window.max_timestamp() rather than .end
Attachments
Issue Links
- links to