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 | 4 months ago
  1. 0

    Inputs to Flatten had incompatible window windowFns when CoGroupByKey with CalendarWindows

    Stack Overflow | 4 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
  2. 0
    You should define the TestContext class in your classpath
  3. 0
    You can solve this by using an actual Service instead of an IntentService
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0
    In cause your problem comes because of mediastore, you have to try changing Albums.ALBUM_ID, to Albums._ID
  6. 0
    All look like I had something else running on my machine that was interfering with it. Once I rebooted it runs without issue.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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