diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java
index 41b6afdf53..97efec4eef 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/EventuallyConsistentMapImpl.java
@@ -922,15 +922,19 @@ public class EventuallyConsistentMapImpl<K, V>
             items.forEach(item -> map.compute(item.key(), (key, existing) ->
                     item.isNewerThan(existing) ? item : existing));
             communicationExecutor.execute(() -> {
-                clusterCommunicator.unicast(ImmutableList.copyOf(map.values()),
-                                            updateMessageSubject,
-                                            serializer::encode,
-                                            peer)
-                                   .whenComplete((result, error) -> {
-                                       if (error != null) {
-                                           log.debug("Failed to send to {}", peer, error);
-                                       }
-                                   });
+                try {
+                    clusterCommunicator.unicast(ImmutableList.copyOf(map.values()),
+                            updateMessageSubject,
+                            serializer::encode,
+                            peer)
+                            .whenComplete((result, error) -> {
+                                if (error != null) {
+                                    log.debug("Failed to send to {}", peer, error);
+                                }
+                            });
+                } catch (Exception e) {
+                    log.warn("Failed to send to {}", peer, e);
+                }
             });
         }
     }