From 8508c94e06925d688dd539df93e04f1af1dcea3c Mon Sep 17 00:00:00 2001 From: yue9944882 <291271447@qq.com> Date: Wed, 21 Jul 2021 16:22:35 +0800 Subject: [PATCH] reduce controller test flakiness by distinguishing resource-versions --- .../kubernetes/client/informer/cache/ControllerTest.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/util/src/test/java/io/kubernetes/client/informer/cache/ControllerTest.java b/util/src/test/java/io/kubernetes/client/informer/cache/ControllerTest.java index 8ab7e4c394..d2e62f44a3 100644 --- a/util/src/test/java/io/kubernetes/client/informer/cache/ControllerTest.java +++ b/util/src/test/java/io/kubernetes/client/informer/cache/ControllerTest.java @@ -36,7 +36,12 @@ public void testControllerProcessDeltas() { AtomicInteger receivingDeltasCount = new AtomicInteger(0); V1Pod foo1 = new V1Pod().metadata(new V1ObjectMeta().name("foo1").namespace("default")); V1Pod foo2 = new V1Pod().metadata(new V1ObjectMeta().name("foo2").namespace("default")); - V1Pod foo3 = new V1Pod().metadata(new V1ObjectMeta().name("foo3").namespace("default")); + V1Pod foo3 = + new V1Pod() + .metadata(new V1ObjectMeta().name("foo3").namespace("default").resourceVersion("rva")); + V1Pod foo3Updated = + new V1Pod() + .metadata(new V1ObjectMeta().name("foo3").namespace("default").resourceVersion("rvb")); V1PodList podList = new V1PodList().metadata(new V1ListMeta()).items(Arrays.asList(foo1, foo2, foo3)); @@ -44,7 +49,7 @@ public void testControllerProcessDeltas() { ListerWatcher listerWatcher = new MockRunOnceListerWatcher( - podList, new Watch.Response(EventType.MODIFIED.name(), foo3)); + podList, new Watch.Response(EventType.MODIFIED.name(), foo3Updated)); Controller controller = new Controller<>(