diff --git a/internal/writenode/data_sync_service_test.go b/internal/writenode/data_sync_service_test.go
index df82cec4d9..4825780360 100644
--- a/internal/writenode/data_sync_service_test.go
+++ b/internal/writenode/data_sync_service_test.go
@@ -236,7 +236,7 @@ func newMeta() {
 			},
 			{
 				FieldID:     0,
-				Name:        "RawID",
+				Name:        "RowID",
 				Description: "test collection filed 1",
 				DataType:    schemapb.DataType_INT64,
 				TypeParams: []*commonpb.KeyValuePair{
diff --git a/internal/writenode/flush_sync_service_test.go b/internal/writenode/flush_sync_service_test.go
index 4c62cfcacf..7da80503d6 100644
--- a/internal/writenode/flush_sync_service_test.go
+++ b/internal/writenode/flush_sync_service_test.go
@@ -89,6 +89,12 @@ func TestFlushSyncService_Start(t *testing.T) {
 			time.Sleep(time.Millisecond * 50)
 		}
 
+		for {
+			if len(ddChan) == 0 && len(insertChan) == 0 {
+				break
+			}
+		}
+
 		ret, err := fService.metaTable.getSegBinlogPaths(SegID)
 		assert.NoError(t, err)
 		assert.Equal(t, map[int64][]string{