fix: flaky TestFuncOffsetManager

Signed-off-by: napallday <[email protected]>
IBM · Aug 20, 2023 · a29d212 · a29d212
1 parent 8681621
commit a29d212
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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)