This is an automated email from the ASF dual-hosted git repository.
bbende pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from e505e8b NIFI-8352 This closes #4922. Changed assertServerConnections
to loop and sleep while evaluating
add 321e979 NIFI-8353: When receiving data via load-balanced connection,
throw an Exception (resulting in an ABORT_TRANSACTION status code) when
attempting to add received FlowFiles to the FlowFile queue, if the node is not
currently connected to cluster. In this case, ensure that we remove the
received FlowFiles from the FlowFile Repository and emit a DROP event to the
repository (with appropriate details) to coincide with the already-committed
Provenance events. Also ensure that w [...]
No new revisions were added by this update.
Summary of changes:
.../queue/IllegalClusterStateException.java | 6 +-
.../queue/LoadBalancedFlowFileQueue.java | 4 +-
.../nifi-framework/nifi-framework-core/pom.xml | 4 -
.../org/apache/nifi/controller/FlowController.java | 2 +-
.../clustered/SocketLoadBalancedFlowFileQueue.java | 10 ++-
.../async/nio/NioAsyncLoadBalanceClient.java | 22 +++++-
.../nio/NioAsyncLoadBalanceClientFactory.java | 8 +-
.../server/StandardLoadBalanceProtocol.java | 72 ++++++++++++++++-
...cryptedSequentialAccessWriteAheadLogTest.groovy | 37 +--------
.../queue/clustered/LoadBalancedQueueIT.java | 77 +++++++++---------
.../server/TestStandardLoadBalanceProtocol.java | 7 +-
.../repository/TestFileSystemRepository.java | 92 ++++++----------------
12 files changed, 182 insertions(+), 159 deletions(-)
copy
nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/put/JsonProcessingError.java
=>
nifi-framework-api/src/main/java/org/apache/nifi/controller/queue/IllegalClusterStateException.java
(83%)
