I am trying to understand how the load balancing works in NiFi 1.8.0.
I have a 2-node Cluster. I set an UpdateAttribute to set the value of a
property, "balancer", to either 0 or 1. I am using stateful EL for this:
${getStateValue('balancer'):plus(1):mod(2)}.
The connection for the output of the UpdateAttribute processor is load
balanced.
Load Balance Strategy: Partition by attribute
Attribute name: balancer
The queue in the connection contains 5 objects, but when I perform a "List
queue", I only see 3 flowfiles. All of the flowfiles are on the same Node,
and as expected have the same "balancer" attribute value.
Presumably, the other 2 flowfiles were load-balanced to the other Node.
However, they should still be visible in List queue, correct?
Perhaps related, the load balance icon on the connection indicates
"Actively balancing...". There are only two 10 byte files, but the
balancing never seems to complete.
