Fix flow graph manager test (#23007)

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/23003/head
yihao.dai 2023-03-27 17:58:00 +08:00 committed by GitHub
parent 053acd39ec
commit 00bd86724e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions

View File

@ -211,6 +211,7 @@ func TestFlowGraphManager(t *testing.T) {
for _, test := range tests {
t.Run(test.testName, func(t *testing.T) {
Params.DataNodeCfg.MemoryWatermark = test.watermark
Params.DataNodeCfg.MemoryForceSyncEnable = true
for i, memorySize := range test.memorySizes {
vchannel := fmt.Sprintf("%s%d", channelPrefix, i)
vchan := &datapb.VchannelInfo{