Re: DirectRunner timers are not strictly time ordered

[Jan Lukavský]

For a single key. I'm getting into collision of timerId 
`__StatefulParDoGcTimerId` (StatefulDoFnRunner) and my timerId for 
flushing sorted elements in implementation of @RequiresTimeSortedInput. 
The timers are being swapped at the end of input (but it can happen 
anywhere near end of window), which results in state being cleared 
before it gets flushed, which means data loss.

 Jan
On 6/10/19 5:08 PM, Reuven Lax wrote:
Do you mean for a single key or across keys?

On Mon, Jun 10, 2019, 5:11 AM Jan Lukavský <je...@seznam.cz 
<mailto:je...@seznam.cz>> wrote:

    Hi,

    I have come across issue [1], where I'm not sure how to solve this in
    most elegant way.

    Any suggestions?

    Thanks,

      Jan

    [1] https://issues.apache.org/jira/browse/BEAM-7520