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

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

commit 8f123f20831897e18ab606c998a50310c4408948
Merge: 8c54934f8b 9c10eca61d
Author: Daniel Roberts ddanielr <ddani...@gmail.com>
AuthorDate: Wed Jan 8 20:01:01 2025 +0000

    Merge branch '3.1'

 .../accumulo/server/conf/util/ZooInfoViewer.java   |  10 +-
 .../accumulo/server/conf/util/ZooPropEditor.java   |   5 +-
 .../server/conf/util/ZooInfoViewerTest.java        |  48 +++++--
 .../accumulo/tserver/TabletClientHandler.java      |  48 ++++++-
 .../org/apache/accumulo/tserver/TabletServer.java  |   7 +-
 .../accumulo/tserver/session/UpdateSession.java    |   1 +
 .../apache/accumulo/test/CorruptMutationIT.java    | 149 +++++++++++++++++++++
 7 files changed, 246 insertions(+), 22 deletions(-)

diff --cc 
server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
index 0f29d0c165,40d8886cfb..5e7f6286c5
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
@@@ -377,8 -388,26 +377,13 @@@ public class TabletServer extends Abstr
      serverStopRequested = true;
    }
  
 -  private class SplitRunner implements Runnable {
 -    private final Tablet tablet;
 -
 -    public SplitRunner(Tablet tablet) {
 -      this.tablet = tablet;
 -    }
 -
 -    @Override
 -    public void run() {
 -      splitTablet(tablet);
 -    }
 -  }
 -
    public long updateTotalQueuedMutationSize(long additionalMutationSize) {
-     return totalQueuedMutationSize.addAndGet(additionalMutationSize);
+     var newTotal = totalQueuedMutationSize.addAndGet(additionalMutationSize);
+     if (log.isTraceEnabled()) {
+       log.trace("totalQueuedMutationSize is now {} after adding {}", newTotal,
+           additionalMutationSize);
+     }
+     return newTotal;
    }
  
    @Override

Reply via email to