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

Reply via email to