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 9619c055c41cba95b8969123ebc8a5ed81400de5 Author: Saad Ur Rahman <[email protected]> AuthorDate: Sat Apr 30 11:47:43 2022 -0400 [K8s] Removed EBS keys from context. --- .../heron/scheduler/kubernetes/KubernetesContext.java | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/KubernetesContext.java b/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/KubernetesContext.java index 242e4f1fadd..9f589a0f948 100644 --- a/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/KubernetesContext.java +++ b/heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/KubernetesContext.java @@ -81,13 +81,6 @@ public final class KubernetesContext extends Context { public static final String KUBERNETES_VOLUME_NFS_SERVER = "heron.kubernetes.volume.nfs.server"; - // awsElasticBlockStore volume keys - // https://kubernetes.io/docs/concepts/storage/volumes/#awselasticblockstore - public static final String KUBERNETES_VOLUME_AWS_EBS_VOLUME_ID = - "heron.kubernetes.volume.awsElasticBlockStore.volumeID"; - public static final String KUBERNETES_VOLUME_AWS_EBS_FS_TYPE = - "heron.kubernetes.volume.awsElasticBlockStore.fsType"; - // Pod Template ConfigMap: heron.kubernetes.[executor | manager].pod.template public static final String KUBERNETES_POD_TEMPLATE_LOCATION = "heron.kubernetes.%s.pod.template"; @@ -186,14 +179,6 @@ public final class KubernetesContext extends Context { return config.getStringValue(KUBERNETES_VOLUME_NFS_SERVER); } - static String getAwsEbsVolumeId(Config config) { - return config.getStringValue(KUBERNETES_VOLUME_AWS_EBS_VOLUME_ID); - } - - static String getAwsEbsFsType(Config config) { - return config.getStringValue(KUBERNETES_VOLUME_AWS_EBS_FS_TYPE); - } - static boolean hasVolume(Config config) { return isNotEmpty(getVolumeType(config)); }
