Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
Description
When it does so, the ReduceFnRunner throws an exception that the watermark hold is past the end of time
This affects all non-Dataflow runners.
(With additional checks)
Caused by: java.lang.IllegalArgumentException: Assigned TimestampedValueInSingleWindow{value=KV
, timestamp=2017-05-11T15:29:59.999Z, window=[20
17-05-11T15:15:00.000Z..2017-05-11T15:30:00.000Z), pane=PaneInfo{isFirst=true, timing=EARLY, index=0}} to a window [2017-05-11T15:15:
00.000Z..2017-05-11T15:30:00.000Z) with fn org.apache.beam.sdk.util.IdentityWindowFn@58543f9f. Expiry is past end of time. Windowing
strategy WindowingStrategy