X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActor.java;h=0a4e2170e527e0dd74cae73802ae7893eba436be;hp=6e1a13cf0c19669443b9273e1d2703a3ff2dede9;hb=f7f22a2284a7ec28c4a35518934e3f9783d503fa;hpb=93f1b5b561183147a8a8f91a8af89fd6eb56a0a9

diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
index 6e1a13cf0c..0a4e2170e5 100644
--- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
@@ -148,14 +148,18 @@ public abstract class RaftActor extends UntypedPersistentActor {
 
         } else if (message instanceof ReplicatedLogEntry) {
             ReplicatedLogEntry logEntry = (ReplicatedLogEntry) message;
-            LOG.info("Received ReplicatedLogEntry for recovery:{}", logEntry.getIndex());
+            if(LOG.isDebugEnabled()) {
+                LOG.debug("Received ReplicatedLogEntry for recovery:{}", logEntry.getIndex());
+            }
             replicatedLog.append(logEntry);
 
         } else if (message instanceof ApplyLogEntries) {
             ApplyLogEntries ale = (ApplyLogEntries) message;
 
-            LOG.info("Received ApplyLogEntries for recovery, applying to state:{} to {}",
-                context.getLastApplied() + 1, ale.getToIndex());
+            if(LOG.isDebugEnabled()) {
+                LOG.debug("Received ApplyLogEntries for recovery, applying to state:{} to {}",
+                    context.getLastApplied() + 1, ale.getToIndex());
+            }
 
             for (long i = context.getLastApplied() + 1; i <= ale.getToIndex(); i++) {
                 applyState(null, "recovery", replicatedLog.get(i).getData());
@@ -198,7 +202,9 @@ public abstract class RaftActor extends UntypedPersistentActor {
 
         } else if (message instanceof ApplyLogEntries){
             ApplyLogEntries ale = (ApplyLogEntries) message;
-            LOG.info("Persisting ApplyLogEntries with index={}", ale.getToIndex());
+            if(LOG.isDebugEnabled()) {
+                LOG.debug("Persisting ApplyLogEntries with index={}", ale.getToIndex());
+            }
             persist(new ApplyLogEntries(ale.getToIndex()), new Procedure<ApplyLogEntries>() {
                 @Override
                 public void apply(ApplyLogEntries param) throws Exception {