diff --git a/plugins/affinity-group-processors/host-affinity/src/main/java/org/apache/cloudstack/affinity/HostAffinityProcessor.java b/plugins/affinity-group-processors/host-affinity/src/main/java/org/apache/cloudstack/affinity/HostAffinityProcessor.java
index 055a6442e1a..0e7c536b0f9 100644
--- a/plugins/affinity-group-processors/host-affinity/src/main/java/org/apache/cloudstack/affinity/HostAffinityProcessor.java
+++ b/plugins/affinity-group-processors/host-affinity/src/main/java/org/apache/cloudstack/affinity/HostAffinityProcessor.java
@@ -81,7 +81,9 @@ public class HostAffinityProcessor extends AffinityProcessorBase implements Affi
         Set<Long> hostIds = new HashSet<>();
         for (Long groupVMId : vmIds) {
             VMInstanceVO groupVM = _vmInstanceDao.findById(groupVMId);
-            hostIds.add(groupVM.getHostId());
+            if (groupVM != null && groupVM.getHostId() != null) {
+                hostIds.add(groupVM.getHostId());
+            }
         }
         return hostIds;
     }