This is an automated email from the ASF dual-hosted git repository. dlmarion 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 7de6d57b40 Log tablet file differences on refresh RPC call (#3879) 7de6d57b40 is described below commit 7de6d57b40f7cd4fa4a6b22e1e322a013c30d048 Author: Dave Marion <dlmar...@apache.org> AuthorDate: Mon Oct 23 16:57:08 2023 -0400 Log tablet file differences on refresh RPC call (#3879) Fixes #3669 --- .../main/java/org/apache/accumulo/tserver/tablet/Tablet.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java index f08c5e367e..f08922fa8c 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java @@ -104,6 +104,8 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.google.common.base.Preconditions; +import com.google.common.collect.Sets; +import com.google.common.collect.Sets.SetView; import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; import io.opentelemetry.api.trace.Span; @@ -1538,6 +1540,15 @@ public class Tablet extends TabletBase { var prevMetadata = latestMetadata; latestMetadata = tabletMetadata; + if (log.isDebugEnabled() && !prevMetadata.getFiles().equals(latestMetadata.getFiles())) { + SetView<StoredTabletFile> removed = + Sets.difference(prevMetadata.getFiles(), latestMetadata.getFiles()); + SetView<StoredTabletFile> added = + Sets.difference(latestMetadata.getFiles(), prevMetadata.getFiles()); + log.debug("Tablet {} was refreshed. Files removed: {} Files added: {}", this.getExtent(), + removed, added); + } + if (refreshPurpose == RefreshPurpose.MINC_COMPLETION) { // Atomically replace the in memory map with the new file. Before this synch block a scan // starting would see the in memory map. After this synch block it should see the file in