Re: Apache Dataflow Template (Python)/ partially OT

2020-04-08 Thread Luke Cwik
Reach out to Google Cloud support. On Wed, Apr 8, 2020 at 1:51 AM Marco Mistroni wrote: > Hi all > Was wondering if anyone has experience similar > I kicked off 3 dataflow template s via cloud function. It has created 3 VM > which are still alive after jobs completed and I cannot delete them...

Send elements to next window under condition after triggering

2020-04-08 Thread Eddy G
So far been dealing with a scenario in Apache Beam where given a certain HTTP code, I may be preserving the elements to restart in the next iteration. Been implementing this with inner code, only using a time trigger. .apply( "Sample Window", Window.into(FixedWind

Re: Apache Dataflow Template (Python)/ partially OT

2020-04-08 Thread Marco Mistroni
Hi all Was wondering if anyone has experience similar I kicked off 3 dataflow template s via cloud function. It has created 3 VM which are still alive after jobs completed and I cannot delete them Could anyone assist with this? Kind regards On Mon, Apr 6, 2020, 3:00 PM Marco Mistroni wrote: