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 19:35:34 UTC
[incubator-heron] 01/07: [K8s] Removed old code to add Empty Directory.
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 6c2e0f58c2446babf1044a889912e9166fb4c82d
Author: Saad Ur Rahman <sa...@apache.org>
AuthorDate: Sun May 1 14:59:50 2022 -0400
[K8s] Removed old code to add Empty Directory.
Updated V1Controller to use VolumeFactory for Empty Directory generation.
---
.../heron/scheduler/kubernetes/V1Controller.java | 21 ++-------------------
1 file changed, 2 insertions(+), 19 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 cfe4a9d923e..dd54b3e32ff 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
@@ -1238,25 +1238,8 @@ public class V1Controller extends KubernetesController {
for (Map.Entry<String, Map<KubernetesConstants.VolumeConfigKeys, String>> configs
: mapOfOpts.entrySet()) {
final String volumeName = configs.getKey();
- final V1Volume volume = new V1VolumeBuilder()
- .withName(volumeName)
- .withNewEmptyDir()
- .endEmptyDir()
- .build();
-
- for (Map.Entry<KubernetesConstants.VolumeConfigKeys, String> config
- : configs.getValue().entrySet()) {
- switch(config.getKey()) {
- case medium:
- volume.getEmptyDir().medium(config.getValue());
- break;
- case sizeLimit:
- volume.getEmptyDir().sizeLimit(new Quantity(config.getValue()));
- break;
- default:
- break;
- }
- }
+ final V1Volume volume = Volumes.get()
+ .create(Volumes.VolumeType.EmptyDir, volumeName, configs.getValue());
volumes.add(volume);
volumeMounts.add(createVolumeMountsCLI(volumeName, configs.getValue()));
}