diff --git a/server/src/main/java/com/cloud/server/StatsCollector.java b/server/src/main/java/com/cloud/server/StatsCollector.java
index 1e0138f7cf90..c0331e8981f9 100644
--- a/server/src/main/java/com/cloud/server/StatsCollector.java
+++ b/server/src/main/java/com/cloud/server/StatsCollector.java
@@ -1226,6 +1226,10 @@ protected void runInContext() {
 
                 Map<Object, Object> metrics = new HashMap<>();
                 for (HostVO host : hosts) {
+                    if (HypervisorType.KVM.equals(host.getHypervisorType()) && ManagementServerNode.getManagementServerId() != host.getManagementServerId()) {
+                        logger.debug("Skipping VM stat collection for [{}] as it is connected to another Management Server node [{}].", host, host.getManagementServerId());
+                        continue;
+                    }
                     Date timestamp = new Date();
                     Pair<Map<Long, VMInstanceVO>, Map<String, Long>> vmsAndMap = getVmMapForStatsForHost(host);
                     Map<Long, VMInstanceVO> vmMap = vmsAndMap.first();