Thank you Luke. I changed DefaultTrigger.of() to AfterProcessingTime.
pastFirstElementInPane() and it worked.
On Mon, Jun 29, 2020 at 9:09 AM Luke Cwik wrote:
> The UpdateFn won't be invoked till the side input is ready which requires
> either the watermark to pass the end of the global window +
The UpdateFn won't be invoked till the side input is ready which requires
either the watermark to pass the end of the global window + allowed
lateness (to show that the side input is empty) or at least one firing to
populate it with data. See this general section on side inputs[1] and some
useful p
Hi All - I am facing an issue while using *side-input*.
*What am I doing:*
>From my main program, I am calling a custom PTransform with a
PCollectionView as parameter. Inside custom PTransform, I am passing the
PCollectionView as a side-input to a DoFn.
*Issue:*
When I run the pipeline, I am expe