[accumulo] branch 1451-external-compactions-feature updated: Don't do work if no external compaction ids

[dl...@apache.org]

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

dlmarion pushed a commit to branch 1451-external-compactions-feature
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/1451-external-compactions-feature by this push:
     new ea0a604  Don't do work if no external compaction ids
ea0a604 is described below

commit ea0a6049f364dfd6ba5cc8e35a65a80eb5f6adc7
Author: Dave Marion <dl...@apache.org>
AuthorDate: Mon May 3 18:30:00 2021 +0000

    Don't do work if no external compaction ids
---
 .../org/apache/accumulo/coordinator/DeadCompactionDetector.java  | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/DeadCompactionDetector.java b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/DeadCompactionDetector.java
index 46c6de5..afd2e2d 100644
--- a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/DeadCompactionDetector.java
+++ b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/DeadCompactionDetector.java
@@ -123,10 +123,11 @@ public class DeadCompactionDetector {
         .stream().flatMap(tm -> tm.getExternalCompactions().keySet().stream())
         .forEach(danglingEcids::remove);
 
-    danglingEcids.forEach(
-        ecid -> log.debug("Detected dangling external compaction final state marker {}", ecid));
-
-    context.getAmple().deleteExternalCompactionFinalStates(danglingEcids);
+    if (!danglingEcids.isEmpty()) {
+      danglingEcids.forEach(
+          ecid -> log.debug("Detected dangling external compaction final state marker {}", ecid));
+      context.getAmple().deleteExternalCompactionFinalStates(danglingEcids);
+    }
   }
 
   public void start() {