From b187bb289de6ba2dae2926a636afa2d89a4d55fb Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Thu, 7 Jan 2021 11:47:39 +0800 Subject: [PATCH] Fix writenode flush sync test Signed-off-by: XuanYang-cn --- internal/writenode/data_sync_service_test.go | 2 +- internal/writenode/flush_sync_service_test.go | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) 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{