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

Portable Flink runner skips timers when dynamic timer tags are used

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • 2.27.0
    • 2.29.0
    • runner-flink
    • None

    Description

      Timers in Flink runner do not fire as expected. See attached example code for details.

      Attachments

        1. timer_test.py
          3 kB
          Marek Pikulski

        Issue Links

          is related to

          Bug - A problem which impairs or prevents the functions of the product. BEAM-8460 Flink/Spark runner ignores UsesStrictTimerOrdering category tests

          • P3 - Non-urgent bugs, features, and improvements
          • Resolved

          Activity

            People

              Unassigned Unassigned
              pikulmar Marek Pikulski
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: