[GitHub] [beam] lukecwik commented on a change in pull request #12260: [BEAM-10486] Update OffsetRestrictionTracker to honor failed claim attempt marking the claim as done when checkpointing.

2020-07-14 Thread GitBox
lukecwik commented on a change in pull request #12260: URL: https://github.com/apache/beam/pull/12260#discussion_r454803546 ## File path: sdks/python/apache_beam/io/restriction_trackers.py ## @@ -92,7 +92,8 @@ def __init__(self, offset_range): self._checkpointed = False

[GitHub] [beam] lukecwik commented on a change in pull request #12260: [BEAM-10486] Update OffsetRestrictionTracker to honor failed claim attempt marking the claim as done when checkpointing.

2020-07-14 Thread GitBox
lukecwik commented on a change in pull request #12260: URL: https://github.com/apache/beam/pull/12260#discussion_r454798710 ## File path: sdks/python/apache_beam/io/restriction_trackers.py ## @@ -92,7 +92,8 @@ def __init__(self, offset_range): self._checkpointed = False