java.lang.IllegalStateException: Inputs to Flatten had incompatible window windowFns: com.google.cloud.dataflow.sdk.transforms.windowing.CalendarWindows$DaysWindows@6af9fcb2, com.google.cloud.dataflow.sdk.transforms.windowing.CalendarWindows$DaysWindows@6cce16f4

Stack Overflow | Manuel Alvarez | 5 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Inputs to Flatten had incompatible window windowFns when CoGroupByKey with CalendarWindows

    Stack Overflow | 5 months ago | Manuel Alvarez
    java.lang.IllegalStateException: Inputs to Flatten had incompatible window windowFns: com.google.cloud.dataflow.sdk.transforms.windowing.CalendarWindows$DaysWindows@6af9fcb2, com.google.cloud.dataflow.sdk.transforms.windowing.CalendarWindows$DaysWindows@6cce16f4

    Root Cause Analysis

    1. java.lang.IllegalStateException

      Inputs to Flatten had incompatible window windowFns: com.google.cloud.dataflow.sdk.transforms.windowing.CalendarWindows$DaysWindows@6af9fcb2, com.google.cloud.dataflow.sdk.transforms.windowing.CalendarWindows$DaysWindows@6cce16f4

      at com.google.cloud.dataflow.sdk.transforms.Flatten$FlattenPCollectionList.apply()
    2. com.google.cloud
      KeyedPCollectionTuple.apply
      1. com.google.cloud.dataflow.sdk.transforms.Flatten$FlattenPCollectionList.apply(Flatten.java:121)
      2. com.google.cloud.dataflow.sdk.transforms.Flatten$FlattenPCollectionList.apply(Flatten.java:105)
      3. com.google.cloud.dataflow.sdk.runners.PipelineRunner.apply(PipelineRunner.java:74)
      4. com.google.cloud.dataflow.sdk.runners.DataflowPipelineRunner.apply(DataflowPipelineRunner.java:413)
      5. com.google.cloud.dataflow.sdk.Pipeline.applyInternal(Pipeline.java:367)
      6. com.google.cloud.dataflow.sdk.Pipeline.applyTransform(Pipeline.java:274)
      7. com.google.cloud.dataflow.sdk.values.PCollectionList.apply(PCollectionList.java:175)
      8. com.google.cloud.dataflow.sdk.transforms.join.CoGroupByKey.apply(CoGroupByKey.java:124)
      9. com.google.cloud.dataflow.sdk.transforms.join.CoGroupByKey.apply(CoGroupByKey.java:74)
      10. com.google.cloud.dataflow.sdk.runners.PipelineRunner.apply(PipelineRunner.java:74)
      11. com.google.cloud.dataflow.sdk.runners.DataflowPipelineRunner.apply(DataflowPipelineRunner.java:413)
      12. com.google.cloud.dataflow.sdk.Pipeline.applyInternal(Pipeline.java:367)
      13. com.google.cloud.dataflow.sdk.Pipeline.applyTransform(Pipeline.java:290)
      14. com.google.cloud.dataflow.sdk.transforms.join.KeyedPCollectionTuple.apply(KeyedPCollectionTuple.java:116)
      14 frames