This is an automated email from the ASF dual-hosted git repository.
dlmarion 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 4a51ea49ff Log information about wal entries and size when closed
(#6569)
4a51ea49ff is described below
commit 4a51ea49ff0d4d8e3b804e177f6098e32a450d39
Author: Dave Marion <[email protected]>
AuthorDate: Thu Oct 1 15:56:51 2026 -0400
Log information about wal entries and size when closed (#6569)
---
.../src/main/java/org/apache/accumulo/tserver/TabletServer.java | 5 ++---
.../src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java | 6 ++++++
.../java/org/apache/accumulo/tserver/log/TabletServerLogger.java | 4 +++-
3 files changed, 11 insertions(+), 4 deletions(-)
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
index b6fc4695f4..ecb2687180 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
@@ -1425,11 +1425,10 @@ public class TabletServer extends AbstractServer
closedLogs.add(currentLog);
clSize = closedLogs.size();
}
- log.info("Marking " + currentLog.getPath() + " as closed. Total closed
logs " + clSize);
+ log.info("Marking {} as closed. Total closed logs: {} ",
currentLog.getPath(), clSize);
walMarker.closeWal(getTabletSession(), currentLog.getPath());
} else {
- log.info(
- "Marking " + currentLog.getPath() + " as unreferenced (skipping
closed writes == 0)");
+ log.info("Marking {} as unreferenced (skipping closed writes == 0)",
currentLog.getPath());
walMarker.walUnreferenced(getTabletSession(), currentLog.getPath());
}
}
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
index c404214bac..90e6735149 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
@@ -37,6 +37,7 @@ import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;
+import java.util.Objects;
import java.util.Optional;
import java.util.UUID;
import java.util.concurrent.CountDownLatch;
@@ -567,6 +568,11 @@ public class DfsLogger implements Comparable<DfsLogger> {
return writes;
}
+ public synchronized long getBytesWritten() {
+ Objects.requireNonNull(logFile, "logFile is null");
+ return logFile.getPos();
+ }
+
public LoggerOperation defineTablet(CommitSession cs) throws IOException {
// write this log to the METADATA table
final LogFileKey key = new LogFileKey();
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
index 7c7dc3e670..caa6ace170 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
@@ -328,7 +328,7 @@ public class TabletServerLogger {
// it's possible the log was advertised in ZK even though we got an
// exception. If there's a chance the WAL marker may have been
created,
// this will ensure it's closed. Either the close will be written
and
- // the GC will clean it up, or the tserver is about to die due to
sesson
+ // the GC will clean it up, or the tserver is about to die due to
session
// expiration and the GC will also clean it up.
try {
tserver.walogClosed(alog);
@@ -371,6 +371,8 @@ public class TabletServerLogger {
if (currentLog != null) {
try {
currentLog.close();
+ log.info("Closing write-ahead log: {}, entries written: {}, bytes
written: {}",
+ currentLog.getFileName(), currentLog.getWrites(),
currentLog.getBytesWritten());
} catch (DfsLogger.LogClosedException ex) {
// ignore
} catch (Exception ex) {
