[BEAM-1553] OutputTimeFn maybe should be allowed to move elements back in time

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-core
• Labels: starter
• Assignee: Unassigned
• Reporter: Thomas Groh
• Created: 24/Feb/17 23:24
• Updated: 03/Jun/22 16:22

Description

EG in this flink failure

https://builds.apache.org/job/beam_PostCommit_Java_RunnableOnService_Flink/org.apache.beam$beam-runners-flink_2.10/1749/testReport/junit/org.apache.beam.sdk.transforms.windowing/WindowTest/testNoWindowFnDoesNotReassignWindows/

Caused by: java.lang.IllegalStateException: OutputTimeFn moved element from 1970-01-01T00:00:00.015Z to earlier time 1970-01-01T00:00:00.009Z for window [1970-01-01T00:00:00.005Z..1970-01-01T00:00:00.010Z)