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 b0706bf6db88b9a6d0152e2c78aeff1cbd9b9153 Author: Saad Ur Rahman <[email protected]> AuthorDate: Sat Apr 30 11:48:27 2022 -0400 [K8s] removed factory type for EBS. --- .../org/apache/heron/scheduler/kubernetes/Volumes.java | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/Volumes.java b/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/Volumes.java index 90f15bd7334..5d97dd4ba80 100644 --- a/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/Volumes.java +++ b/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/Volumes.java @@ -40,7 +40,6 @@ final class Volumes { private Volumes() { volumes.put(HOST_PATH, new HostPathVolumeFactory()); volumes.put(NFS, new NfsVolumeFactory()); - volumes.put(AWS_EBS, new AwsEbsVolumeFactory()); } static Volumes get() { @@ -95,21 +94,4 @@ final class Volumes { return volume; } } - - static class AwsEbsVolumeFactory implements VolumeFactory { - @Override - public V1Volume create(Config config) { - final V1Volume volume = newVolume(config); - - final String volumeId = KubernetesContext.getAwsEbsVolumeId(config); - final String fsType = KubernetesContext.getAwsEbsFsType(config); - V1AWSElasticBlockStoreVolumeSource awsElasticBlockStoreVolumeSource = - new V1AWSElasticBlockStoreVolumeSource() - .volumeID(volumeId) - .fsType(fsType); - volume.setAwsElasticBlockStore(awsElasticBlockStoreVolumeSource); - - return volume; - } - } }
