This is an automated email from the ASF dual-hosted git repository. saadurrahman pushed a commit to branch saadurrahman/3821-Remove-Deprecated-Volumes-K8s-dev in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
commit 6c2e0f58c2446babf1044a889912e9166fb4c82d Author: Saad Ur Rahman <[email protected]> AuthorDate: Sun May 1 14:59:50 2022 -0400 [K8s] Removed old code to add Empty Directory. Updated V1Controller to use VolumeFactory for Empty Directory generation. --- .../heron/scheduler/kubernetes/V1Controller.java | 21 ++------------------- 1 file changed, 2 insertions(+), 19 deletions(-) diff --git a/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/V1Controller.java b/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/V1Controller.java index cfe4a9d923e..dd54b3e32ff 100644 --- a/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/V1Controller.java +++ b/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/V1Controller.java @@ -1238,25 +1238,8 @@ public class V1Controller extends KubernetesController { for (Map.Entry<String, Map<KubernetesConstants.VolumeConfigKeys, String>> configs : mapOfOpts.entrySet()) { final String volumeName = configs.getKey(); - final V1Volume volume = new V1VolumeBuilder() - .withName(volumeName) - .withNewEmptyDir() - .endEmptyDir() - .build(); - - for (Map.Entry<KubernetesConstants.VolumeConfigKeys, String> config - : configs.getValue().entrySet()) { - switch(config.getKey()) { - case medium: - volume.getEmptyDir().medium(config.getValue()); - break; - case sizeLimit: - volume.getEmptyDir().sizeLimit(new Quantity(config.getValue())); - break; - default: - break; - } - } + final V1Volume volume = Volumes.get() + .create(Volumes.VolumeType.EmptyDir, volumeName, configs.getValue()); volumes.add(volume); volumeMounts.add(createVolumeMountsCLI(volumeName, configs.getValue())); }
