This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a change to tag HDF-3.4.1.74-2-tag
in repository https://gitbox.apache.org/repos/asf/nifi.git
*** WARNING: tag HDF-3.4.1.74-2-tag was deleted! ***
was eef06907a0 Fixed dependency
This change permanently discards the following revisions:
discard eef06907a0 Fixed dependency
discard 9411804049 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 7a5cc3789f 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 bf2eda57b4 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 9b83d5173a 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 6cd702770a 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 13a13f2092 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 10fc6ec791 NIFI-6677: Update ListHDFS to clear state (when
appropriate) in an @OnScheduled method, just as AbstractListProcessor does,
instead of doing it in onTrigger. Doing it in onTrigger is problematic because
in a cluster, the Primary Node may run for some period of time, perhaps days or
months. Then, when the Primary Node chagnes, onTrigger gets called for the
first time on the new Primary Node, and this triggers the processor to clear
state.
discard bf5f0a45e7 NIFI-6028: Code refactoring to address review feedback
discard e8db91daab NIFI-6028: Updates to ignore changes between local version
of a flow and a remote version of a flow if the difference is the addition of a
new property that has the default value
discard 83d93d0b36 NIFI-6339: Only call @OnConfigurationRestored method on
components when they are created if FlowController has been initialized