(accumulo) branch main updated: Replaced System.currentTimeMillis() with System.nanoTime() in DfsLogger (#4250)

[domgarguilo]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new d91178f44c Replaced System.currentTimeMillis() with System.nanoTime() 
in DfsLogger (#4250)
d91178f44c is described below

commit d91178f44cd00cbdc1f305675c9f36a36ab86d96
Author: Arbaaz Khan <bazzy...@yahoo.com>
AuthorDate: Mon Feb 12 15:49:44 2024 -0500

    Replaced System.currentTimeMillis() with System.nanoTime() in DfsLogger 
(#4250)
    
    * Replaced System.currentTimeMillis() with System.nanoTime()
---
 .../main/java/org/apache/accumulo/tserver/log/DfsLogger.java   | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

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 c0ed0aed39..020144f9d9 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
@@ -20,6 +20,8 @@ package org.apache.accumulo.tserver.log;
 
 import static java.nio.charset.StandardCharsets.UTF_8;
 import static java.util.Collections.singletonList;
+import static java.util.concurrent.TimeUnit.MILLISECONDS;
+import static java.util.concurrent.TimeUnit.NANOSECONDS;
 import static org.apache.accumulo.tserver.logger.LogEvents.COMPACTION_FINISH;
 import static org.apache.accumulo.tserver.logger.LogEvents.COMPACTION_START;
 import static org.apache.accumulo.tserver.logger.LogEvents.DEFINE_TABLET;
@@ -172,7 +174,7 @@ public final class DfsLogger implements 
Comparable<DfsLogger> {
           }
         }
 
-        long start = System.currentTimeMillis();
+        long start = System.nanoTime();
         try {
           if (shouldHSync.isPresent()) {
             if (shouldHSync.orElseThrow()) {
@@ -186,9 +188,9 @@ public final class DfsLogger implements 
Comparable<DfsLogger> {
         } catch (IOException | RuntimeException ex) {
           fail(work, ex, "synching");
         }
-        long duration = System.currentTimeMillis() - start;
-        if (duration > slowFlushMillis) {
-          log.info("Slow sync cost: {} ms, current pipeline: {}", duration,
+        long duration = System.nanoTime() - start;
+        if (duration > MILLISECONDS.toNanos(slowFlushMillis)) {
+          log.info("Slow sync cost: {} ms, current pipeline: {}", 
NANOSECONDS.toMillis(duration),
               Arrays.toString(getPipeLine()));
           if (expectedReplication > 0) {
             int current = expectedReplication;