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
