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

New bundles may start within snapshotState

    XMLWordPrintableJSON

Details

    Description

      The Flink runner finishes bundles as part of snapshotState. In the portable runner, it is possible that a new bundle will be started as part of finishing the bundle when the bundleFinishedCallback is invoked. This happens when the watermark advances and timers get fired.

       

      Attachments

        Issue Links

          is related to

          Bug - A problem which impairs or prevents the functions of the product. BEAM-7112 State cleanup interferes with user timer callback

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

          Web Link GitHub Pull Request #8426

          Activity

            People

              mxm Maximilian Michels
              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 - 1h 20m
                  1h 20m