Hi,

I'm experiencing errors in validates runner of flink (1.8) on current master. The failure is

java.lang.AssertionError: processing bundle should have been called before 
finish bundle
Expected: is <PROCESS_ELEMENT>
     but: was <START_BUNDLE>
        at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:18)
        at 
org.apache.beam.sdk.transforms.ParDoLifecycleTest$ExceptionThrowingFn.postBundle(ParDoLifecycleTest.java:379)


Does anyone else see this? Seems to affect PRs as well.

Jan

Reply via email to