I remember +Reza Rokni <r...@google.com> +Maximilian Michels
<m...@apache.org> knowing
/ talking about this.
Best
-P.

On Thu, Oct 31, 2019 at 9:30 AM Reuven Lax <re...@google.com> wrote:

> Have you seen these failures on Dataflow as well? From code examination I
> would expect Dataflow to have some bugs in this area as well (especially if
> a timer is set while processing a bundle). If the tests are passing on
> Dataflow this might mean that we need different tests (or it might mean
> that Dataflow is "working" for some mysterious reason that is not obvious
> from the code :) ).
>
> On Wed, Oct 23, 2019 at 2:54 AM Jan Lukavský <je...@seznam.cz> wrote:
>
>> Hi,
>>
>> as part of [1] a new set of validatesRunner tests has been introduced.
>> These tests (currently marked as category UsesStrictTimerOrdering)
>> verify that runners fire timers in increasing timestamp under all
>> circumstances. After adding these validatesRunner tests, Samza [2] and
>> Portable Flink [3] started to fail these tests. I have created the
>> tracking issues for that, because that behavior should be fixed (timers
>> in wrong order can cause erratic behavior and/or data loss).
>>
>> I'm writing to anyone interested in solving these issues.
>>
>> Cheers,
>>
>>   Jan
>>
>> [1] https://issues.apache.org/jira/browse/BEAM-7520
>>
>> [2] https://issues.apache.org/jira/browse/BEAM-8459
>>
>> [3] https://issues.apache.org/jira/browse/BEAM-8460
>>
>>

Reply via email to