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

State cleanup interferes with user timer callback

    XMLWordPrintableJSON

Details

    Description

      Cleanup timers and user timers are fired at the watermark. Processing of timers in the SDK worker is asynchronous, so it is possible that the state is already removed when the user timer callback executes.

      Attachments

        Issue Links

          is related to

          Bug - A problem which impairs or prevents the functions of the product. BEAM-6876 User state cleanup in portable Flink runner

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          relates to

          Bug - A problem which impairs or prevents the functions of the product. BEAM-7126 Double encoding of state keys in portable Flink runner

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved

          Bug - A problem which impairs or prevents the functions of the product. BEAM-7171 New bundles may start within snapshotState

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          links to

          Web Link GitHub Pull Request #8351

          Web Link GitHub Pull Request #8399

          Activity

            People

              thw Thomas Weise
              thw Thomas Weise
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 9h 10m
                  9h 10m