You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by sa...@apache.org on 2022/05/01 00:13:03 UTC
[incubator-heron] 02/10: [K8s] removed factory type for EBS.
This is an automated email from the ASF dual-hosted git repository.
saadurrahman pushed a commit to branch 3821-Remove-Deprecated-Volumes-K8s-dev
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
commit b0706bf6db88b9a6d0152e2c78aeff1cbd9b9153
Author: Saad Ur Rahman <sa...@apache.org>
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;
- }
- }
}