Skip to content

Commit 9d1699b

Browse files
committed
Fix scaling case for the same offering
1 parent 9b7ee63 commit 9d1699b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

plugins/integrations/kubernetes-service/src/main/java/com/cloud/kubernetes/cluster/actionworkers/KubernetesClusterScaleWorker.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -583,7 +583,10 @@ public boolean scaleCluster() throws CloudRuntimeException {
583583

584584
protected boolean isServiceOfferingScalingNeededForNodeType(KubernetesClusterNodeType nodeType,
585585
Map<String, ServiceOffering> map, KubernetesCluster kubernetesCluster) {
586-
Long existingOfferingId = getExistingOfferingIdForNodeType(nodeType, kubernetesCluster);
586+
// DEFAULT node type means only the global service offering has been set for the Kubernetes cluster
587+
Long existingOfferingId = map.containsKey(DEFAULT.name()) ?
588+
kubernetesCluster.getServiceOfferingId() :
589+
getExistingOfferingIdForNodeType(nodeType, kubernetesCluster);
587590
if (existingOfferingId == null) {
588591
logAndThrow(Level.ERROR, String.format("The Kubernetes cluster %s does not have a global service offering set", kubernetesCluster.getName()));
589592
}

0 commit comments

Comments
 (0)