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 <dlmar...@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() {