fix unit test

pingcap · Aug 24, 2021 · 563e5da · 563e5da
1 parent 26b24e4
commit 563e5da
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cdc/sink/mq_test.go b/cdc/sink/mq_test.go
@@ -79,6 +79,7 @@ func (s mqSinkSuite) TestKafkaSink(c *check.C) {
 		},
 		StartTs:  100,
 		CommitTs: 120,
+		Columns:  []*model.Column{{Name: "col1", Type: 1, Value: "aa"}},
 	}
 	err = sink.EmitRowChangedEvents(ctx, row)
 	c.Assert(err, check.IsNil)