Have you used Dataflow's update feature on this pipeline? Also, do you have the code for your WindowFn?
On Tue, Jan 7, 2020 at 12:05 PM Aaron Dixon <[email protected]> wrote: > Dataflow. (See stacktrace) > > On Tue, Jan 7, 2020 at 1:50 PM Reuven Lax <[email protected]> wrote: > >> Which runner are you using? >> >> On Tue, Jan 7, 2020, 11:17 AM Aaron Dixon <[email protected]> wrote: >> >>> I get an IllegalStateException "<window> is in more than one state >>> address window set" (stacktrace below). >>> >>> What does this mean? What invariant of custom window implementation >>> & merging am I violating? >>> >>> Thank you for any advise. >>> >>> ``` >>> java.lang.IllegalStateException: >>> {[2019-12-05T01:36:48.870Z..2019-12-05T01:36:48.871Z),terminal} is in more >>> than one state address window set >>> at >>> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkState >>> (Preconditions.java:588) >>> at >>> org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.MergingActiveWindowSet.checkInvariants >>> (MergingActiveWindowSet.java:334) >>> at >>> org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.MergingActiveWindowSet.persist >>> (MergingActiveWindowSet.java:88) >>> at >>> org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.ReduceFnRunner.persist >>> (ReduceFnRunner.java:380) >>> at >>> org.apache.beam.runners.dataflow.worker.StreamingGroupAlsoByWindowViaWindowSetFn.processElement >>> (StreamingGroupAlsoByWindowViaWindowSetFn.java:96) >>> ... >>> ``` >>> >>
