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

Migrate ByteKeyRangeTracker to use tryClaim(ByteKey.EMPTY) as end of range claim instead of markDone

    XMLWordPrintableJSON

Details

    Description

      org.apache.beam.sdk.transforms.splittabledofn.ByteKeyRangeTracker doesn't handle tryClaim(ByteKey.EMPTY) and the related doneness check or checkpointing since doneness checking can't handle the empty interval, checkpointing returns invalid checkpoints or errors out since it is using the lastClaimedKey vs the lastAttemptedKey for doneness checking

      Attachments

        Activity

          People

            lcwik Luke Cwik
            lcwik Luke Cwik
            Votes:
            0 Vote for this issue
            Watchers:
            1 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 - 2h 40m
                2h 40m