From 563e5da2e1ab1afc4a012f3fdf5cd7eccbf62cf4 Mon Sep 17 00:00:00 2001 From: amyangfei Date: Tue, 24 Aug 2021 14:28:18 +0800 Subject: [PATCH] fix unit test --- cdc/sink/mq_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/cdc/sink/mq_test.go b/cdc/sink/mq_test.go index a87946d50d2..40421fb3c30 100644 --- 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)