diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java
index 4665411..34f8b4a 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java
@@ -1228,7 +1228,7 @@
                         .toList();
 
                 if (nodeIds.size() == 1 && nodeIds.get(0).equals(self)) {
-                    log.debug("No other peers in the cluster.");
+                    log.trace("No other peers in the cluster.");
                     return;
                 }
 
@@ -1358,7 +1358,7 @@
 
         @Override
         public void handle(ClusterMessage message) {
-            log.debug("Received Device Anti-Entropy advertisement from peer: {}", message.sender());
+            log.trace("Received Device Anti-Entropy advertisement from peer: {}", message.sender());
             DeviceAntiEntropyAdvertisement advertisement = SERIALIZER.decode(message.payload());
             handleAdvertisement(advertisement);
         }
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/flow/impl/DistributedFlowRuleStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/flow/impl/DistributedFlowRuleStore.java
index 14dfd0d..f7718c1 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/flow/impl/DistributedFlowRuleStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/flow/impl/DistributedFlowRuleStore.java
@@ -188,7 +188,7 @@
             @Override
             public void handle(ClusterMessage message) {
                 FlowRule rule = SERIALIZER.decode(message.payload());
-                log.debug("received get flow entry request for {}", rule);
+                log.trace("received get flow entry request for {}", rule);
                 FlowEntry flowEntry = getFlowEntryInternal(rule);
                 try {
                     message.respond(SERIALIZER.encode(flowEntry));
@@ -203,7 +203,7 @@
             @Override
             public void handle(ClusterMessage message) {
                 DeviceId deviceId = SERIALIZER.decode(message.payload());
-                log.debug("Received get flow entries request for {} from {}", deviceId, message.sender());
+                log.trace("Received get flow entries request for {} from {}", deviceId, message.sender());
                 Set<FlowEntry> flowEntries = getFlowEntriesInternal(deviceId);
                 try {
                     message.respond(SERIALIZER.encode(flowEntries));
@@ -255,7 +255,7 @@
             return getFlowEntryInternal(rule);
         }
 
-        log.debug("Forwarding getFlowEntry to {}, which is the primary (master) for device {}",
+        log.trace("Forwarding getFlowEntry to {}, which is the primary (master) for device {}",
                 replicaInfo.master().orNull(), rule.deviceId());
 
         ClusterMessage message = new ClusterMessage(
@@ -301,7 +301,7 @@
             return getFlowEntriesInternal(deviceId);
         }
 
-        log.debug("Forwarding getFlowEntries to {}, which is the primary (master) for device {}",
+        log.trace("Forwarding getFlowEntries to {}, which is the primary (master) for device {}",
                 replicaInfo.master().orNull(), deviceId);
 
         ClusterMessage message = new ClusterMessage(
@@ -359,7 +359,7 @@
             return storeBatchInternal(operation);
         }
 
-        log.debug("Forwarding storeBatch to {}, which is the primary (master) for device {}",
+        log.trace("Forwarding storeBatch to {}, which is the primary (master) for device {}",
                 replicaInfo.master().orNull(), deviceId);
 
         ClusterMessage message = new ClusterMessage(
@@ -459,7 +459,7 @@
             return addOrUpdateFlowRuleInternal(rule);
         }
 
-        log.error("Tried to update FlowRule {} state,"
+        log.warn("Tried to update FlowRule {} state,"
                 + " while the Node was not the master.", rule);
         return null;
     }
@@ -504,7 +504,7 @@
             return removeFlowRuleInternal(rule);
         }
 
-        log.error("Tried to remove FlowRule {},"
+        log.warn("Tried to remove FlowRule {},"
                 + " while the Node was not the master.", rule);
         return null;
     }
@@ -542,14 +542,14 @@
 
         flowEntriesLock.writeLock().lock();
         try {
-            log.info("Loading FlowRules for {} from backups", did);
+            log.debug("Loading FlowRules for {} from backups", did);
             SMap<FlowId, ImmutableList<StoredFlowEntry>> backupFlowTable = smaps.get(did);
             for (Entry<FlowId, ImmutableList<StoredFlowEntry>> e
                     : backupFlowTable.entrySet()) {
 
                 // TODO: should we be directly updating internal structure or
                 // should we be triggering event?
-                log.debug("loading {}", e.getValue());
+                log.trace("loading {}", e.getValue());
                 for (StoredFlowEntry entry : e.getValue()) {
                     flowEntries.remove(did, entry);
                     flowEntries.put(did, entry);
@@ -570,7 +570,7 @@
         } finally {
             flowEntriesLock.writeLock().unlock();
         }
-        log.debug("removedFromPrimary {}", removed);
+        log.trace("removedFromPrimary {}", removed);
     }
 
     private static final class TimeoutFuture
@@ -594,7 +594,7 @@
         @Override
         public void handle(final ClusterMessage message) {
             FlowRuleBatchOperation operation = SERIALIZER.decode(message.payload());
-            log.info("received batch request {}", operation);
+            log.debug("received batch request {}", operation);
 
             final DeviceId deviceId = operation.getOperations().get(0).getTarget().deviceId();
             ReplicaInfo replicaInfo = replicaInfoManager.getReplicaInfoFor(deviceId);
@@ -704,7 +704,7 @@
         @Override
         public void run() {
             try {
-                log.debug("update backup {} +{} -{}", deviceId, toAdd, toRemove);
+                log.trace("update backup {} +{} -{}", deviceId, toAdd, toRemove);
                 final SMap<FlowId, ImmutableList<StoredFlowEntry>> backupFlowTable = smaps.get(deviceId);
                 // Following should be rewritten using async APIs
                 for (StoredFlowEntry entry : toAdd) {
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java
index 3b233f7..fb64435 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java
@@ -459,7 +459,7 @@
         @Override
         public void handle(ClusterMessage message) {
 
-            log.info("Received host update event from peer: {}", message.sender());
+            log.debug("Received host update event from peer: {}", message.sender());
             InternalHostEvent event = (InternalHostEvent) SERIALIZER.decode(message.payload());
 
             ProviderId providerId = event.providerId();
@@ -475,7 +475,7 @@
         @Override
         public void handle(ClusterMessage message) {
 
-            log.info("Received host removed event from peer: {}", message.sender());
+            log.debug("Received host removed event from peer: {}", message.sender());
             InternalHostRemovedEvent event = (InternalHostRemovedEvent) SERIALIZER.decode(message.payload());
 
             HostId hostId = event.hostId();
@@ -503,7 +503,7 @@
                         .toList();
 
                 if (nodeIds.size() == 1 && nodeIds.get(0).equals(self)) {
-                    log.debug("No other peers in the cluster.");
+                    log.trace("No other peers in the cluster.");
                     return;
                 }
 
@@ -640,7 +640,7 @@
 
         @Override
         public void handle(ClusterMessage message) {
-            log.debug("Received Host Anti-Entropy advertisement from peer: {}", message.sender());
+            log.trace("Received Host Anti-Entropy advertisement from peer: {}", message.sender());
             HostAntiEntropyAdvertisement advertisement = SERIALIZER.decode(message.payload());
             handleAntiEntropyAdvertisement(advertisement);
         }
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java
index d4b0916..2ae6cd8 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java
@@ -638,7 +638,7 @@
                         .toList();
 
                 if (nodeIds.size() == 1 && nodeIds.get(0).equals(self)) {
-                    log.debug("No other peers in the cluster.");
+                    log.trace("No other peers in the cluster.");
                     return;
                 }
 
@@ -796,7 +796,7 @@
 
         @Override
         public void handle(ClusterMessage message) {
-            log.debug("Received Link Anti-Entropy advertisement from peer: {}", message.sender());
+            log.trace("Received Link Anti-Entropy advertisement from peer: {}", message.sender());
             LinkAntiEntropyAdvertisement advertisement = SERIALIZER.decode(message.payload());
             handleAntiEntropyAdvertisement(advertisement);
         }
diff --git a/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java b/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java
index dcb953a..7627f5c 100644
--- a/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java
+++ b/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java
@@ -49,12 +49,12 @@
 
     @Override
     public void run(Timeout timeout) throws Exception {
-        log.debug("Collecting stats for {}", this.sw.getStringId());
+        log.trace("Collecting stats for {}", this.sw.getStringId());
 
         sendFlowStatistics();
 
         if (!this.stopTimer) {
-            log.debug("Scheduling stats collection in {} seconds for {}",
+            log.trace("Scheduling stats collection in {} seconds for {}",
                     this.refreshInterval, this.sw.getStringId());
             timeout.getTimer().newTimeout(this, refreshInterval,
                     TimeUnit.SECONDS);