Fix writenode flush sync test

Signed-off-by: XuanYang-cn <xuan.yang@zilliz.com>
This commit is contained in:
XuanYang-cn 2021-01-07 11:47:39 +08:00 committed by yefu.chen
parent 70785e8896
commit b187bb289d
2 changed files with 7 additions and 1 deletions

View File

@ -236,7 +236,7 @@ func newMeta() {
},
{
FieldID: 0,
Name: "RawID",
Name: "RowID",
Description: "test collection filed 1",
DataType: schemapb.DataType_INT64,
TypeParams: []*commonpb.KeyValuePair{

View File

@ -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{