This is an automated email from the ASF dual-hosted git repository.
markap14 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 65ba4a2 NIFI-6853 - flowFileEvent combineCounters hashmap overwritten
- Added unit test to verify behavior of contribution
new 7731609 NIFI-6787 - Before: When checking if a load balanced
connection queue is full, we compare the totalSize.get() and getMaxQueueSize().
After: Go over all partitions and see if all of them are full. Wrapping
RoundRobinPartitioner in a (new) AvailableSeekingPartitioner which selects a
new partition if the currently selected one is full.
new e05d11c NIFI-6787: Added a comment to the UI tooltip, user guide, and
javadocs to indicate that round robin may skip a node if that node is not
receiving the data as fast as other nodes in the cluster, in order to maximum
throughput.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
nifi-docs/src/main/asciidoc/user-guide.adoc | 4 +-
.../nifi/controller/queue/LoadBalanceStrategy.java | 3 +-
.../clustered/SocketLoadBalancedFlowFileQueue.java | 14 +-
.../partition/AvailableSeekingPartitioner.java | 62 +++++++
.../TestRoundRobinFlowFileQueueBalancing.java | 203 +++++++++++++++++++++
.../nifi-web-ui/src/main/webapp/js/nf/nf-common.js | 3 +-
6 files changed, 285 insertions(+), 4 deletions(-)
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/partition/AvailableSeekingPartitioner.java
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/queue/clustered/TestRoundRobinFlowFileQueueBalancing.java
