From 111782076c3eda3a924cafb5da701e5c42f95cfa Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Thu, 2 Nov 2023 18:40:11 +0800 Subject: [PATCH] fix tests. --- cdc/processor/pipeline/table_actor_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cdc/processor/pipeline/table_actor_test.go b/cdc/processor/pipeline/table_actor_test.go index b763c808929..9c0fcf51c09 100644 --- a/cdc/processor/pipeline/table_actor_test.go +++ b/cdc/processor/pipeline/table_actor_test.go @@ -101,7 +101,8 @@ func TestTableActorInterface(t *testing.T) { require.Equal(t, model.Ts(5), table.ResolvedTs()) ctx, cancel := context.WithCancel(context.Background()) eg, egCtx := errgroup.WithContext(ctx) - table.redoDMLMgr, _ = redo.NewDMLManager(ctx, &config.ConsistentConfig{ + changefeedID := model.DefaultChangeFeedID("test") + table.redoDMLMgr = redo.NewDMLManager(changefeedID, &config.ConsistentConfig{ Level: string(redoCfg.ConsistentLevelEventual), FlushIntervalInMs: redoCfg.MinFlushIntervalInMs, Storage: fmt.Sprintf("file://tmp/%s", t.TempDir()),