The Spark runner provides "timeout" options for streaming, and monitoring is the same as Spark (Metrics, Sinks, etc.)
On Mon, Apr 25, 2016 at 8:25 PM kaniska Mandal <[email protected]> wrote: > Whats the recommended approach > > > to reliably shut down the pipeline > > > to run the beam-flink pipeline in a scheduled manner > > > tomonitor the rates/throughputs/throttling/multiple threads spawned - > by Pipeline , any suggestion ? > > Thanks > Kaniska >
