Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-1553

OutputTimeFn maybe should be allowed to move elements back in time

Details

    • Bug
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • runner-core

    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)

      Attachments

        Activity

          People

            Unassigned Unassigned
            tgroh Thomas Groh
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: