[
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)
