(accumulo) branch elasticity updated: fixes CompactionPriorityQueueMetricsIT (#4200)

[kturner]

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

kturner pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/elasticity by this push:
     new da3631e8ee fixes CompactionPriorityQueueMetricsIT (#4200)
da3631e8ee is described below

commit da3631e8ee0801f2c04091db609bd9f5ed725731
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Fri Jan 26 17:29:22 2024 -0500

    fixes CompactionPriorityQueueMetricsIT (#4200)
    
    CompactionPriorityQueueMetricsIT was waiting for a queue to report zero
    size.  However when the queue is empty it may be removed and then no
    reports are generated for it.  Added an additional check for zero total
    queues to the test.
---
 .../test/compaction/CompactionPriorityQueueMetricsIT.java         | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/compaction/CompactionPriorityQueueMetricsIT.java
 
b/test/src/main/java/org/apache/accumulo/test/compaction/CompactionPriorityQueueMetricsIT.java
index e89f96dfaa..a1e45815f0 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/compaction/CompactionPriorityQueueMetricsIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/compaction/CompactionPriorityQueueMetricsIT.java
@@ -393,6 +393,14 @@ public class CompactionPriorityQueueMetricsIT extends 
SharedMiniClusterBase {
             emptyQueue = true;
           }
         }
+
+        // Check if the total number of queues is zero, if so then will not 
see metrics for the
+        // above queue.
+        if 
(metric.getName().equals(MetricsProducer.METRICS_COMPACTOR_JOB_PRIORITY_QUEUES))
 {
+          if (Integer.parseInt(metric.getValue()) == 0) {
+            emptyQueue = true;
+          }
+        }
       }
       UtilWaitThread.sleep(3500);
     }