fix check error

pingcap · Jan 10, 2022 · 64626e5 · 64626e5
1 parent 0faabce
commit 64626e5
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
@@ -602,7 +602,7 @@ func (s *outputSuite) TestFlushSinkReleaseFlowController(c *check.C) {
 	flowController := &flushFlowController{}
 	sink := &flushSink{}
 	// sNode is a sinkNode
-	sNode := newSinkNode(sink, 0, 10, flowController)
+	sNode := newSinkNode(1, sink, 0, 10, flowController)
 	c.Assert(sNode.Init(pipeline.MockNodeContext4Test(ctx, pipeline.Message{}, nil)), check.IsNil)
 	sNode.barrierTs = 10