Fix block device mapping logic

pinterest · Sep 12, 2024 · 1442eff · 1442eff
1 parent b988eb9
commit 1442eff
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...n-server/src/main/java/com/pinterest/orion/core/actions/aws/ReplaceEC2InstanceAction.java b/...n-server/src/main/java/com/pinterest/orion/core/actions/aws/ReplaceEC2InstanceAction.java
@@ -413,7 +413,7 @@ protected InstanceStateAndRequest getInstanceStateAndRequest(Ec2Client ec2Client
         if (cluster.containsAttribute(KafkaCluster.ATTR_EBS_VOLUME_SIZE_KEY)) {
           overrideEbsVolumeSize = cluster.getAttribute(KafkaCluster.ATTR_EBS_VOLUME_SIZE_KEY).getValue();
           if (overrideEbsVolumeSize > 0)
-            updateBlockDeviceMappings(ec2Client, targetAmi);
+            blockDeviceMappings = updateBlockDeviceMappings(ec2Client, targetAmi);
         }
         // build launch instance request based on source of instance info
         RunInstancesRequest runInstancesRequest = getRunInstancesRequestFromInstance(userdata, victim, targetAmi, blockDeviceMappings);
@@ -500,7 +500,7 @@ protected List<BlockDeviceMapping> updateBlockDeviceMappings(
       .build();
     newBDMs.add(blockDeviceMapping);
     logger().info(
-      "Volume size override requested for:" + hostname);
+      "EBS volume size override of " + overrideEbsVolumeSize + "GB requested for:" + hostname);
     return newBDMs;
   }