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