From a29d21293efb29825d6197987ed7b7ede17fa093 Mon Sep 17 00:00:00 2001 From: napallday Date: Sun, 20 Aug 2023 23:29:16 +0800 Subject: [PATCH] fix: flaky TestFuncOffsetManager Signed-off-by: napallday --- functional_offset_manager_test.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/functional_offset_manager_test.go b/functional_offset_manager_test.go index 7f324b22bd..e3bfbd6f95 100644 --- a/functional_offset_manager_test.go +++ b/functional_offset_manager_test.go @@ -30,6 +30,9 @@ func TestFuncOffsetManager(t *testing.T) { pom1.MarkOffset(10, "test metadata") safeClose(t, pom1) + // Avoid flaky test: submit offset & let om cleanup removed poms + offsetManager.Commit() + pom2, err := offsetManager.ManagePartition("test.1", 0) if err != nil { t.Fatal(err)