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