From 53f600d5f3f318e57d036de90b2330b084d56d38 Mon Sep 17 00:00:00 2001
From: napallday <bzx0619@gmail.com>
Date: Sun, 20 Aug 2023 23:29:16 +0800
Subject: [PATCH] fix: flaky TestFuncOffsetManager

Signed-off-by: napallday <bzx0619@gmail.com>
---
 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 7f324b22b..e3bfbd6f9 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)