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;