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 <[email protected]> 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("")
