You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2022/09/29 13:19:14 UTC

[accumulo] branch main updated: Reduce compaction error to debug (#2981)

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 9fc349603e Reduce compaction error to debug (#2981)
9fc349603e is described below

commit 9fc349603e3d5f5c52fcea632f0bd80e022e5ff6
Author: Mike Miller <mm...@apache.org>
AuthorDate: Thu Sep 29 13:19:10 2022 +0000

    Reduce compaction error to debug (#2981)
    
    * Closes #2978
---
 .../java/org/apache/accumulo/tserver/tablet/CompactableImpl.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableImpl.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableImpl.java
index e7ec5856ab..e4660ea964 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableImpl.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableImpl.java
@@ -439,8 +439,11 @@ public class CompactableImpl implements Compactable {
                 Set<StoredTabletFile> candidates = new HashSet<>(selectedFiles);
                 candidates.removeAll(allCompactingFiles);
                 candidates = Collections.unmodifiableSet(candidates);
-                Preconditions.checkState(currFiles.containsAll(candidates),
-                    "selected files not in all files %s %s", candidates, currFiles);
+                // verify that candidates are still around and fail quietly if not
+                if (!currFiles.containsAll(candidates)) {
+                  log.debug("Selected files not in all files {} {}", candidates, currFiles);
+                  return Set.of();
+                }
                 return candidates;
               } else {
                 return Set.of();