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/07/21 03:25:53 UTC
[incubator-heron] 03/05: [StatefulSet] removed references to functions in K8s Shim.
This is an automated email from the ASF dual-hosted git repository.
saadurrahman pushed a commit to branch saadurrahman/3846-Refactoring-K8s-Shim-dev
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
commit abfa1378105798f984c9ac13f703bb33cfbf7697
Author: Saad Ur Rahman <sa...@apache.org>
AuthorDate: Wed Jul 20 23:23:51 2022 -0400
[StatefulSet] removed references to functions in K8s Shim.
---
.../org/apache/heron/scheduler/kubernetes/StatefulSetTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/heron/schedulers/tests/java/org/apache/heron/scheduler/kubernetes/StatefulSetTest.java b/heron/schedulers/tests/java/org/apache/heron/scheduler/kubernetes/StatefulSetTest.java
index 10f48845b5f..d58c42102c1 100644
--- a/heron/schedulers/tests/java/org/apache/heron/scheduler/kubernetes/StatefulSetTest.java
+++ b/heron/schedulers/tests/java/org/apache/heron/scheduler/kubernetes/StatefulSetTest.java
@@ -63,6 +63,7 @@ import io.kubernetes.client.openapi.models.V1VolumeMountBuilder;
import static org.apache.heron.scheduler.kubernetes.KubernetesConstants.VolumeConfigKeys;
import static org.apache.heron.scheduler.kubernetes.KubernetesUtils.TestTuple;
+import static org.apache.heron.scheduler.kubernetes.StatefulSet.getTolerations;
@RunWith(MockitoJUnitRunner.class)
public class StatefulSetTest {
@@ -428,7 +429,7 @@ public class StatefulSetTest {
.effect("Some Effect")
.tolerationSeconds(5L);
final List<V1Toleration> expectedTolerationBase =
- Collections.unmodifiableList(KubernetesShim.getTolerations());
+ Collections.unmodifiableList(getTolerations());
final List<V1Toleration> inputTolerationsBase = Collections.unmodifiableList(
Arrays.asList(
new V1Toleration()
@@ -526,7 +527,7 @@ public class StatefulSetTest {
final V1PersistentVolumeClaim claimOne = new V1PersistentVolumeClaimBuilder()
.withNewMetadata()
.withName(volumeNameOne)
- .withLabels(KubernetesShim.getPersistentVolumeClaimLabels(topologyName))
+ .withLabels(StatefulSet.getPersistentVolumeClaimLabels(topologyName))
.endMetadata()
.withNewSpec()
.withStorageClassName(storageClassName)
@@ -541,7 +542,7 @@ public class StatefulSetTest {
final V1PersistentVolumeClaim claimStatic = new V1PersistentVolumeClaimBuilder()
.withNewMetadata()
.withName(volumeNameStatic)
- .withLabels(KubernetesShim.getPersistentVolumeClaimLabels(topologyName))
+ .withLabels(StatefulSet.getPersistentVolumeClaimLabels(topologyName))
.endMetadata()
.withNewSpec()
.withStorageClassName("")