Eugene Kirpichov created BEAM-2607: -------------------------------------- Summary: 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
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 (v6.4.14#64029)