From 00bd86724e917516544c225dbbc1ee4c94b9ef80 Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Mon, 27 Mar 2023 17:58:00 +0800 Subject: [PATCH] Fix flow graph manager test (#23007) Signed-off-by: bigsheeper --- internal/datanode/flow_graph_manager_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/datanode/flow_graph_manager_test.go b/internal/datanode/flow_graph_manager_test.go index 5671c93e32..ec01d1b971 100644 --- a/internal/datanode/flow_graph_manager_test.go +++ b/internal/datanode/flow_graph_manager_test.go @@ -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{