fix: flaky TestFuncOffsetManager

Signed-off-by: napallday <bzx0619@gmail.com>
IBM · Aug 21, 2023 · 5cd9fa6 · 5cd9fa6
1 parent 1bcf2d9
commit 5cd9fa6
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)