Following branch adds debug output that explains how the side input becomes "ready" even when no input was received. Once the side input watermark surpasses the end of the window, all pushed back input will be processed, causing the calls to the side input handler.
https://github.com/tweise/beam/tree/wordcountFix ``` ... ###addSideInputValue: Tag<ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_52@side1> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ###addSideInputValue: Tag<ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_53@side1> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ###getIterable: Tag<ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_52@side0> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ###getIterable: Tag<ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_52@side1> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ### processing pushed back data ###getIterable: Tag<ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_53@side0> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ###getIterable: Tag<ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_53@side2> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ###getIterable: Tag<ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_53@side1> window: org.apache.beam.sdk.transforms.windowing.GlobalWindow@2f0185c1 ``` [ Full content available at: https://github.com/apache/beam/pull/6325 ] This message was relayed via gitbox.apache.org for [email protected]
