This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a change to tag HDF-3.4.1.115-2-tag
in repository https://gitbox.apache.org/repos/asf/nifi.git
*** WARNING: tag HDF-3.4.1.115-2-tag was deleted! ***
was bae143562b HOTFIX-3737: Fix build issue and test problems caused by
cherry-picks
This change permanently discards the following revisions:
discard bae143562b HOTFIX-3737: Fix build issue and test problems caused by
cherry-picks
discard 6a450ff01f HOTFIX-3737 NIFI-7117: When SocketLoadBalancedFlowFileQueue
creates its array of Queue Partitions in the constructor, it added the local
partition as the first element in that list. This list should be ordered the
same across all nodes in the cluster. By making the local partition the first
in the array, each node had a different ordering of these partitions. As a
result, Partition by Attribute strategy would constantly rebalance flowfiles
that it received to other nod [...]
discard 6f82620ec2 HOTFIX-3737: NIFI-7076: This closes #4024. Revert
"NIFI-6787 - Before: When checking if a load balanced connection queue is full,
we compare the totalSize.get() and getMaxQueueSize()."
discard 7744fd05a9 HOTFIX-3737: 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.
discard 47bdcc5245 HOTFIX-3737: 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.
discard ed01f7d6c1 HOTFIX-3737: NIFI-6760: When writing/reading the length of
a DataFrame, do so usin… (#3801)
discard 6f8481520b HOTFIX-3737: NIFI-6759: When encountering Exception during
load-balanced connection communications, after closing socket, return from
method rather than continuing loop
discard 325d4e04ba HOTFIX-3737: NIFI-6736: Create thread on demand to handle
incoming request from client for load balancing. This allows us to avoid
situations where we don't have enough threads and we block on the server side,
waiting for data, when clients are trying to send data in another connection
discard 21b8ab9c45 HOTFIX-3737: NIFI-6696: Ensured that callback to
RemoteQueuePartition do not attempt to obtain the Partition Read Lock. The Read
Lock is not necessary as long as the 'partitioner' is volatile, because it
doesn't matter whether or not the actual partitions themselves change, since
the only partition that would be touched is the Rebalancing Partition,on, which
is fixed. Obtaining the partition read lock can lead to a deadlock as outlined
in the Jira description.
discard 892aa8a73f HOTFIX-3737: NIFI-6517: Ensure that if IOException is
thrown from LoadBalanceSession that we properly catch the Exception, mark
session as complete, and then re-throw. There was one condition in which this
was not occurring. This commit addresses that situation.
discard ede24261d1 HOTFIX-3737: NIFI-6353: If LoadBalanceSession determines
remote node's queue is full, mark session complete and penalize the Partition,
rather than just penalizing the session. This allows the client to move on to
another session, which avoids an issue where backpressure on one queue can
prevent data from being transferred between nodes in another queue
discard 0cf04e99ee HOTFIX-3737: NIFI-6285: Addressed issue that resulted in
swapped data not being swapped back in if load balancing strategy changed while
data was swapped out; added integration tests for swapping. In testing, also
encountered an issue with data being swapped out while swap files were being
recovered causing the queue size to be wrong and causing errors about not being
able to swap data in, because it attempted to swap the data in twice.
discard 2747a681bd HOTFIX-3737: NIFI-6183: Implemented base class for
Framework-level integration tests that is responsible for instantiating the key
components for integration tests, including FlowController,
WriteAheadFlowFileRepository, WriteAheadProvenanceRepository,
FileSystemRepository, FileSystemSwapManager, StandardFlowFileQueue,
StandardProcessScheduler, etc. Implemented several integration tests to span
different parts of the framework
discard d2dcc05230 HOTFIX-3715 NIFI-6983: Ensure that if any call to kafka's
Producer throws a ProducerFencedException that it's handled properly by
poisoning the lease, which in turn will close the client
discard c38c436e16 NIFI-7758: Avoid calling InetAddress.getHostName() because
doing so results in a reverse DNS Lookup, which can be expensive
discard d0d115c72b HOTFIX-3384: Contains the following changes: * NIFI-7079
security fix * NIFI-6085 - need for sec fix * NIFI-6280 - need for sec fix *
additional changes which needed for successful build
discard cd5b7527b0 [HOTFIX-3384] NIFI-7023 This closes #3991. Removed SLF4J
and Log4J transitive dependencies from Zookeeper so tests log correctly.
Changed template handling. Added unit tests.
