fix tests.

pingcap · Nov 2, 2023 · 1117820 · 1117820
1 parent 9441e8a
commit 1117820
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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()),