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 2a5c30ec7bbbbf9d89e54e99cdba7e6f4da2324c Author: Saad Ur Rahman <[email protected]> AuthorDate: Tue May 3 10:57:45 2022 -0400 [K8s] using Volume Factory to create volumes with PVC. --- .../org/apache/heron/scheduler/kubernetes/V1Controller.java | 10 +--------- 1 file changed, 1 insertion(+), 9 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 9c93e30cf84..1cd85e5ad6f 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 @@ -77,7 +77,6 @@ import io.kubernetes.client.openapi.models.V1StatefulSetSpec; import io.kubernetes.client.openapi.models.V1Status; import io.kubernetes.client.openapi.models.V1Toleration; import io.kubernetes.client.openapi.models.V1Volume; -import io.kubernetes.client.openapi.models.V1VolumeBuilder; import io.kubernetes.client.openapi.models.V1VolumeMount; import io.kubernetes.client.util.PatchUtils; import io.kubernetes.client.util.Yaml; @@ -1145,14 +1144,7 @@ public class V1Controller extends KubernetesController { final String claimName = configs.getValue() .get(KubernetesConstants.VolumeConfigKeys.claimName); if (claimName != null && !KubernetesConstants.LABEL_ON_DEMAND.equalsIgnoreCase(claimName)) { - volumes.add( - new V1VolumeBuilder() - .withName(volumeName) - .withNewPersistentVolumeClaim() - .withClaimName(claimName) - .endPersistentVolumeClaim() - .build() - ); + volumes.add(Volumes.get().createPersistentVolumeClaim(claimName, volumeName)); } volumeMounts.add(Volumes.get().createMount(volumeName, configs.getValue())); }
