accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject [accumulo] branch master updated: format MasterTime #1354
Date Wed, 11 Sep 2019 17:06:43 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/master by this push:
     new b978cbd  format MasterTime #1354
b978cbd is described below

commit b978cbd57374632d0a7631c112c7bb810bc74934
Author: Keith Turner <kturner@apache.org>
AuthorDate: Wed Sep 11 13:06:19 2019 -0400

    format MasterTime #1354
---
 .../master/src/main/java/org/apache/accumulo/master/MasterTime.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/server/master/src/main/java/org/apache/accumulo/master/MasterTime.java b/server/master/src/main/java/org/apache/accumulo/master/MasterTime.java
index 6c88a4d..fcd910b 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/MasterTime.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/MasterTime.java
@@ -57,8 +57,7 @@ public class MasterTime extends TimerTask {
     try {
       zk.putPersistentData(zPath, "0".getBytes(UTF_8), NodeExistsPolicy.SKIP);
       skewAmount = new AtomicLong(
-          Long.parseLong(new String(zk.getData(zPath, null), UTF_8))
-              - System.nanoTime());
+          Long.parseLong(new String(zk.getData(zPath, null), UTF_8)) - System.nanoTime());
     } catch (Exception ex) {
       throw new IOException("Error updating master time", ex);
     }
@@ -105,7 +104,8 @@ public class MasterTime extends TimerTask {
       case UNLOAD_METADATA_TABLETS:
       case UNLOAD_ROOT_TABLET:
         try {
-          zk.putPersistentData(zPath, Long.toString(System.nanoTime() + skewAmount.get()).getBytes(UTF_8),
+          zk.putPersistentData(zPath,
+              Long.toString(System.nanoTime() + skewAmount.get()).getBytes(UTF_8),
               NodeExistsPolicy.OVERWRITE);
         } catch (Exception ex) {
           if (log.isDebugEnabled()) {


Mime
View raw message