From 5ec9fbad96042a2d0c7f5abd8a97829b3d7998e2 Mon Sep 17 00:00:00 2001 From: Liquan Pei Date: Thu, 2 May 2024 16:27:33 -0700 Subject: [PATCH] [BUG] Memberlist flaky test --- go/pkg/memberlist_manager/memberlist_manager_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/go/pkg/memberlist_manager/memberlist_manager_test.go b/go/pkg/memberlist_manager/memberlist_manager_test.go index f19cce3b57d..ffc6e784370 100644 --- a/go/pkg/memberlist_manager/memberlist_manager_test.go +++ b/go/pkg/memberlist_manager/memberlist_manager_test.go @@ -154,14 +154,14 @@ func TestMemberlistManager(t *testing.T) { dynamicClient := fake.NewSimpleDynamicClient(runtime.NewScheme(), initialCrMemberlist) // Create a node watcher - nodeWatcher := NewKubernetesWatcher(clientset, namespace, "worker", 1*time.Second) + nodeWatcher := NewKubernetesWatcher(clientset, namespace, "worker", 100*time.Millisecond) // Create a memberlist store memberlistStore := NewCRMemberlistStore(dynamicClient, namespace, memberlist_name) // Create a memberlist manager memberlistManager := NewMemberlistManager(nodeWatcher, memberlistStore) - memberlistManager.SetReconcileInterval(5 * time.Second) + memberlistManager.SetReconcileInterval(1 * time.Second) memberlistManager.SetReconcileCount(1) // Start the memberlist manager