[ https://issues.apache.org/jira/browse/BEAM-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Eugene Kirpichov closed BEAM-2607. ---------------------------------- Resolution: Fixed Fix Version/s: 2.3.0 This was recently fixed. > Enforce that SDF must return stop() after a failed tryClaim() call > ------------------------------------------------------------------ > > Key: BEAM-2607 > URL: https://issues.apache.org/jira/browse/BEAM-2607 > Project: Beam > Issue Type: Bug > Components: sdk-java-core > Reporter: Eugene Kirpichov > Assignee: Eugene Kirpichov > Priority: Major > Fix For: 2.3.0 > > > https://github.com/apache/beam/pull/3360 reintroduces > DoFn.ProcessContinuation with some refinements to its semantics - see > https://issues.apache.org/jira/browse/BEAM-2447. > One of the refinements is that, if the ProcessElement call unsuccessfully > calls tryClaim() on the RestrictionTracker, the call MUST return stop(). > The current JIRA is to enforce this automatically. Right now this is not > possible because tryClaim() is not formally a method in RestrictionTracker > (only concrete classes provide it, but not the base class) and runners can > not hook into it. -- This message was sent by Atlassian JIRA (v7.6.3#76005)