[nifi] branch main updated (e505e8b -> 321e979)

[bb...@apache.org]

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%)