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/03 14:58:07 UTC
[incubator-heron] 04/04: [K8s] using Volume Factory to create volumes with PVC.
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 <sa...@apache.org>
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()));
}