diff --git a/modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZonesUtil.java b/modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZonesUtil.java index e8fed7ed5b3..6316e76bd12 100644 --- a/modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZonesUtil.java +++ b/modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZonesUtil.java @@ -598,6 +598,14 @@ public static Set filterDataNodes( CatalogZoneDescriptor zoneDescriptor, Map nodesAttributes ) { + assert dataNodes != null : "Data nodes are null."; + assert zoneDescriptor.filter() != null : "Filter is null."; + assert zoneDescriptor.storageProfiles().profiles() != null : "Profiles are null"; + for (Node node : dataNodes) { + assert nodesAttributes.get(node.nodeId()) != null : "Node attributes are null [nodeId = " + node.nodeId() + ']'; + assert nodesAttributes.get(node.nodeId()).userAttributes() != null : + "User attributes are null [nodeId = " + node.nodeId() + ']'; + } return dataNodes.stream() .filter(n -> filterNodeAttributes(nodesAttributes.get(n.nodeId()).userAttributes(), zoneDescriptor.filter()))