accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [33/50] [abbrv] git commit: ACCUMULO-378 Better logging for work assigner
Date Wed, 21 May 2014 01:59:52 GMT
ACCUMULO-378 Better logging for work assigner


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/eb4b9ce6
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/eb4b9ce6
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/eb4b9ce6

Branch: refs/heads/ACCUMULO-378
Commit: eb4b9ce60c56ed5f0c2b2b49ae1c9b61edf55a2c
Parents: 2ff3a6c
Author: Josh Elser <elserj@apache.org>
Authored: Mon May 19 13:55:41 2014 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Mon May 19 13:55:41 2014 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/master/replication/WorkDriver.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/eb4b9ce6/server/master/src/main/java/org/apache/accumulo/master/replication/WorkDriver.java
----------------------------------------------------------------------
diff --git a/server/master/src/main/java/org/apache/accumulo/master/replication/WorkDriver.java
b/server/master/src/main/java/org/apache/accumulo/master/replication/WorkDriver.java
index 1b70a13..00b0480 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/replication/WorkDriver.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/replication/WorkDriver.java
@@ -37,6 +37,7 @@ public class WorkDriver extends Daemon {
   private AccumuloConfiguration conf;
 
   private WorkAssigner assigner;
+  private String assignerImplName;
 
   public WorkDriver(Master master, Connector conn) {
     super();
@@ -55,6 +56,7 @@ public class WorkDriver extends Daemon {
     }
 
     this.assigner.configure(conf, conn);
+    this.assignerImplName = assigner.getClass().getName();
     this.setName(assigner.getName());
   }
 
@@ -79,14 +81,14 @@ public class WorkDriver extends Daemon {
 
   @Override
   public void run() {
-    log.info("Starting replication work assignment thread");
+    log.info("Starting replication work assignment thread using {}", assignerImplName);
 
     while (master.stillMaster()) {
       // Assign the work using the configured implementation
       assigner.assignWork();
 
       long sleepTime = conf.getTimeInMillis(Property.REPLICATION_WORK_ASSIGNMENT_SLEEP);
-      log.debug("Sleeping {} ms", sleepTime);
+      log.debug("Sleeping {} ms before next work assignment", sleepTime);
       UtilWaitThread.sleep(sleepTime);
     }
   }


Mime
View raw message