[nifi] branch main updated (f812dfd -> 1f0425b)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

markap14 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.


    from f812dfd  NIFI-8535: Better error message in PutDatabaseRecord when table does not exist (#5070)
     add 2309d75  NIFI-8126 - Added totalActiveQueuedDuration and maxActiveQueuedDuration to the ConnectionStatus object - Updated FlowFileQueue implementations and supporting code to properly calculate and provide the totalActiveQueuedDuration and maxActiveQueuedDuration for their active queues - Fixing failing unit test. In examining this it appears that the unit test only accidentally passed in the past and that the object mocked to always throw an exception was not actually being used [...]
     add 1f0425b  NIFI-8126: Updated verbiage for ConnectionStatusDescriptors, added an Average Queued Duration

No new revisions were added by this update.

Summary of changes:
 .../nifi/controller/status/ConnectionStatus.java   | 24 ++++++
 .../nifi/controller/queue/FlowFileQueue.java       | 11 +++
 .../nifi/controller/repository/SwapSummary.java    | 10 +++
 .../apache/nifi/reporting/AbstractEventAccess.java |  5 ++
 .../nifi/controller/FileSystemSwapManager.java     |  2 +-
 .../controller/queue/StandardFlowFileQueue.java    | 10 +++
 .../controller/queue/SwappablePriorityQueue.java   | 92 +++++++++++++++++++++-
 .../clustered/SocketLoadBalancedFlowFileQueue.java | 33 +++++++-
 .../queue/clustered/partition/QueuePartition.java  | 11 +++
 .../clustered/partition/RemoteQueuePartition.java  | 10 +++
 .../partition/StandardRebalancingPartition.java    | 10 +++
 .../SwappablePriorityQueueLocalPartition.java      | 10 +++
 .../status/history/ConnectionStatusDescriptor.java | 23 +++++-
 .../nifi/controller/swap/SchemaSwapSerializer.java | 12 ++-
 .../controller/swap/SimpleSwapDeserializer.java    |  6 +-
 .../nifi/controller/swap/StandardSwapSummary.java  | 20 ++++-
 .../apache/nifi/controller/swap/SwapSchema.java    | 33 ++++++++
 .../nifi/controller/swap/SwapSummaryFieldMap.java  | 21 ++++-
 .../apache/nifi/controller/MockFlowFileRecord.java | 17 ++--
 .../apache/nifi/controller/MockSwapManager.java    |  8 +-
 .../nifi/controller/TestFileSystemSwapManager.java | 17 ++--
 .../nifi/controller/TestStandardFlowFileQueue.java | 34 ++++++++
 .../TestSocketLoadBalancedFlowFileQueue.java       | 15 +++-
 .../clustered/TestSwappablePriorityQueue.java      | 49 ++++++++++++
 .../repository/TestRocksDBFlowFileRepository.java  |  2 +-
 .../TestWriteAheadFlowFileRepository.java          | 12 ++-
 .../apache/nifi/controller/swap/MockFlowFile.java  |  2 +-
 .../swap/TestSchemaSwapSerializerDeserializer.java |  4 +
 .../stateless/queue/StatelessFlowFileQueue.java    | 19 +++++
 29 files changed, 490 insertions(+), 32 deletions(-)