Skip to content

Commit ae57162

Browse files
committed
fixed flaky test
Signed-off-by: kcruz28 <[email protected]>
1 parent 77d6103 commit ae57162

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

cluster-operator/src/test/java/io/strimzi/operator/cluster/operator/assembly/KafkaMirrorMaker2AssemblyOperatorPodSetTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -427,7 +427,9 @@ public void testScaleDownCluster(VertxTestContext context) {
427427

428428
assertThat(mm2Status.getUrl(), is("http://my-mm2-mirrormaker2-api.my-namespace.svc:8083"));
429429
assertThat(mm2Status.getReplicas(), is(3));
430-
assertThat(mm2Status.getLabelSelector(), is("strimzi.io/cluster=my-mm2,strimzi.io/name=my-mm2-mirrormaker2,strimzi.io/kind=KafkaMirrorMaker2"));
430+
Set<String> expectedLabels = Set.of("strimzi.io/cluster=my-mm2", "strimzi.io/name=my-mm2-mirrormaker2", "strimzi.io/kind=KafkaMirrorMaker2");
431+
Set<String> actualLabels = Set.of(mm2Status.getLabelSelector().split(","));
432+
assertThat(actualLabels, is(expectedLabels));
431433
assertThat(mm2Status.getConditions().get(0).getStatus(), is("True"));
432434
assertThat(mm2Status.getConditions().get(0).getType(), is("Ready"));
433435

0 commit comments

Comments
 (0)