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

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


The following commit(s) were added to refs/heads/2.1 by this push:
     new 1bdad6cdce Adds a log message for rename success (#5991)
1bdad6cdce is described below

commit 1bdad6cdcea9197521a377208d09b77d19e471ed
Author: Daniel Roberts <[email protected]>
AuthorDate: Wed Nov 26 23:43:06 2025 -0500

    Adds a log message for rename success (#5991)
    
    Adds a log message for a successful rename operation.
    Fixes existing log message to use positional args.
---
 core/src/main/java/org/apache/accumulo/core/logging/TabletLogger.java | 4 ++++
 .../main/java/org/apache/accumulo/tserver/tablet/DatafileManager.java | 4 +++-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/logging/TabletLogger.java 
b/core/src/main/java/org/apache/accumulo/core/logging/TabletLogger.java
index c91eb9fd96..747a352c6c 100644
--- a/core/src/main/java/org/apache/accumulo/core/logging/TabletLogger.java
+++ b/core/src/main/java/org/apache/accumulo/core/logging/TabletLogger.java
@@ -121,6 +121,10 @@ public class TabletLogger {
     return Collections2.transform(files, CompactableFile::getFileName);
   }
 
+  public static void renamed(KeyExtent extent, TabletFile src, TabletFile 
dest) {
+    fileLog.debug("{} renamed {} to {}", extent, src.getFileName(), 
dest.getFileName());
+  }
+
   public static void selected(KeyExtent extent, CompactionKind kind,
       Collection<? extends TabletFile> inputs) {
     fileLog.trace("{} changed compaction selection set for {} new set {}", 
extent, kind,
diff --git 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/DatafileManager.java
 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/DatafileManager.java
index ce8c4dcd29..255fcbdcfa 100644
--- 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/DatafileManager.java
+++ 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/DatafileManager.java
@@ -344,6 +344,7 @@ class DatafileManager {
           }
           attemptedRename = true;
           rename(vm, tmpDatafile.getPath(), newDatafile.getPath());
+          TabletLogger.renamed(tablet.getExtent(), tmpDatafile, newDatafile);
         }
         break;
       } catch (IOException ioe) {
@@ -484,7 +485,7 @@ class DatafileManager {
     TabletFile newDatafile = 
CompactableUtils.computeCompactionFileDest(tmpDatafile);
 
     if (vm.exists(newDatafile.getPath())) {
-      log.error("Target map file already exist " + newDatafile, new 
Exception());
+      log.error("Target map file already exists {}", newDatafile, new 
Exception());
       throw new IllegalStateException("Target map file already exist " + 
newDatafile);
     }
 
@@ -494,6 +495,7 @@ class DatafileManager {
       // rename before putting in metadata table, so files in metadata table 
should
       // always exist
       rename(vm, tmpDatafile.getPath(), newDatafile.getPath());
+      TabletLogger.renamed(tablet.getExtent(), tmpDatafile, newDatafile);
     }
 
     Location lastLocation = null;

Reply via email to