Re: DoFn with SideInput

2020-06-29 Thread Praveen K Viswanathan
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 +

Re: DoFn with SideInput

2020-06-29 Thread Luke Cwik
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

DoFn with SideInput

2020-06-28 Thread Praveen K Viswanathan
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