From d717b48f907276884ed0f9470eddae35ca2e291a Mon Sep 17 00:00:00 2001 From: miagilepner Date: Thu, 31 Oct 2024 14:48:22 +0100 Subject: [PATCH] fix flaky TestRaft_Removed (#28817) --- physical/raft/raft_test.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/physical/raft/raft_test.go b/physical/raft/raft_test.go index 0173340dca..8160a144ce 100644 --- a/physical/raft/raft_test.go +++ b/physical/raft/raft_test.go @@ -777,6 +777,10 @@ func TestRaft_Removed(t *testing.T) { addPeer(t, raft1, raft3) physical.ExerciseBackend(t, raft1) + commitIdx := raft1.CommittedIndex() + ensureCommitApplied(t, commitIdx, raft2) + ensureCommitApplied(t, commitIdx, raft3) + require.False(t, raft1.IsRemoved()) require.False(t, raft2.IsRemoved()) require.False(t, raft3.IsRemoved()) @@ -784,7 +788,7 @@ func TestRaft_Removed(t *testing.T) { err := raft1.RemovePeer(context.Background(), raft3.NodeID()) require.NoError(t, err) - require.Eventually(t, raft3.IsRemoved, 5*time.Second, 500*time.Millisecond) + require.Eventually(t, raft3.IsRemoved, 15*time.Second, 500*time.Millisecond) require.False(t, raft1.IsRemoved()) require.False(t, raft2.IsRemoved()) })