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 dbd4fceb16a41f8dd7fd3f0bcd4c08751392d16f Author: Saad Ur Rahman <[email protected]> AuthorDate: Sun May 1 15:26:41 2022 -0400 [K8s] Removed old code to add Network File System. Updated V1Controller to use VolumeFactory for Network File System generation. --- .../heron/scheduler/kubernetes/V1Controller.java | 24 ++-------------------- 1 file changed, 2 insertions(+), 22 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 19986c12a79..338e50bda51 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 @@ -1280,28 +1280,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) - .withNewNfs() - .endNfs() - .build(); - - for (Map.Entry<KubernetesConstants.VolumeConfigKeys, String> config - : configs.getValue().entrySet()) { - switch(config.getKey()) { - case server: - volume.getNfs().setServer(config.getValue()); - break; - case pathOnNFS: - volume.getNfs().setPath(config.getValue()); - break; - case readOnly: - volume.getNfs().setReadOnly(Boolean.parseBoolean(config.getValue())); - break; - default: - break; - } - } + final V1Volume volume = Volumes.get() + .create(Volumes.VolumeType.NetworkFileSystem, volumeName, configs.getValue()); volumes.add(volume); volumeMounts.add(createVolumeMountsCLI(volumeName, configs.getValue())); }
