Nevermind, this is discussed on the PR linked. On Mon, Oct 21, 2019 at 2:11 PM Kyle Weaver <kcwea...@google.com> wrote:
> Do you know why an empty bundle might be created? > > On Mon, Oct 21, 2019 at 1:42 PM Jan Lukavský <je...@seznam.cz> wrote: > >> Hi, >> >> when debugging a flaky ParDoLifecycleTest in FlinkRunner, I have found a >> situation, where Flink might create empty bundle - i.e. call >> @StartBundle immediately followed by @FinishBundle, with no elements >> inside the bundle. That is what breaks the ParDoLifecycleTest, because >> the test explicitly assumes, that the sequence of lifecycle methods >> should be StartBundle -> Process Element -> Finish Bundle. It is easy to >> modify the test to accept situation of StartBundle -> FinishBundle with >> no elements ([1]), but the question is, is this allowed by the model? I >> think there is no reason not to be, but I'd like to be sure. >> >> Thanks, >> >> Jan >> >> [1] https://github.com/apache/beam/pull/9841 >> >>
