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)
