fix ut

pingcap · Jul 2, 2022 · 515377f · 515377f
1 parent 374d695
commit 515377f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/processor/pipeline/sink_test.go b/cdc/processor/pipeline/sink_test.go
@@ -141,7 +141,7 @@ func TestState(t *testing.T) {
 	// test stop at targetTs
 	targetTs := model.Ts(10)
 	node := newSinkNode(1, &mockSink{}, 0, targetTs, &mockFlowController{}, redo.NewDisabledManager(),
-		&state, ctx.ChangefeedVars().ID, false)
+		&state, ctx.ChangefeedVars().ID, true)
 	node.initWithReplicaConfig(pipeline.MockNodeContext4Test(ctx, pmessage.Message{}, nil).
 		ChangefeedVars().Info.Config)
 	require.Equal(t, TableStatePrepared, node.State())