Hello,

We use NiFi in cluster mode in Kubernetes via a StatefulSet. Sometimes, we
need to restart the cluster, so the StatefulSet restarts one pod at a time.
In this scenario, will a given node attempt to process all "in-flight"
FlowFiles to drain the queues as much as possible before shutting down?

I know it's probably impossible to have a completely graceful offload in
these cases, but since the process still receives a termination signal and
has some time before it must stop, it could try to prevent FlowFiles from
staying in the system for too long, but I don't know if there are any
mechanisms to handle this in NiFi.

Regards,
Alexis.

Reply via email to