Hi Omkar,
So what does stopping a samza container mean in context of a Beam Pipeline?
A container shutting down during a rebalance shouldn't affect the beam
application unless the shutdown was unsuccessful.
> Does pres.waitUntilFinish() return when samza container is being stopped ?
>
Hey Bharath,
I probably know what is taking long in my shutdown sequence.
My code roughly looks like this -
https://gist.github.com/omkardeshpande8/dc4259a8aa7a726a4fe787d9ece8f44a
I think Thread.sleep(3) in this code is increasing the time taken for the
shutdown sequence. Is that
Hi Omkar,
The errors are related to timeouts during shutdown which gets triggered
during a rebalance. Whenever a new processor joins the quorum or leaves the
quorum, a rebalance is triggered which requires all the existing processors
to shutdown its container before agreeing on the new job model.
