fix: flaky TestFuncOffsetManager

Signed-off-by: napallday <[email protected]>
IBM · Aug 21, 2023 · 53f600d · 53f600d
1 parent 827ec18
commit 53f600d
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)