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 e5212478c8fb1ba2a4ba77434ab867f0f7ce8787 Author: Saad Ur Rahman <[email protected]> AuthorDate: Sun May 1 15:17:11 2022 -0400 [K8s] Removed old code to add Host Path. Updated V1Controller to use VolumeFactory for Host Path 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 dd54b3e32ff..19986c12a79 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 @@ -1259,25 +1259,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) - .withNewHostPath() - .endHostPath() - .build(); - - for (Map.Entry<KubernetesConstants.VolumeConfigKeys, String> config - : configs.getValue().entrySet()) { - switch(config.getKey()) { - case type: - volume.getHostPath().setType(config.getValue()); - break; - case pathOnHost: - volume.getHostPath().setPath(config.getValue()); - break; - default: - break; - } - } + final V1Volume volume = Volumes.get() + .create(Volumes.VolumeType.HostPath, volumeName, configs.getValue()); volumes.add(volume); volumeMounts.add(createVolumeMountsCLI(volumeName, configs.getValue())); }
