sink(ticdc): fix lint

pingcap · Mar 14, 2022 · ee1567e · ee1567e
1 parent cd973f7
commit ee1567e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/cdc/sink/mq_flush_worker.go b/cdc/sink/mq_flush_worker.go
@@ -129,7 +129,10 @@ func (w *flushWorker) group(events []mqEvent) map[int32][]*model.RowChangedEvent
 }
 
 // asyncSend is responsible for sending messages to the Kafka producer.
-func (w *flushWorker) asyncSend(ctx context.Context, paritionedRows map[int32][]*model.RowChangedEvent) error {
+func (w *flushWorker) asyncSend(
+	ctx context.Context,
+	paritionedRows map[int32][]*model.RowChangedEvent,
+) error {
 	for partition, events := range paritionedRows {
 		for _, event := range events {
 			err := w.encoder.AppendRowChangedEvent(event)

diff --git a/cdc/sink/mq_flush_worker_test.go b/cdc/sink/mq_flush_worker_test.go
@@ -214,7 +214,11 @@ func TestGroup(t *testing.T) {
 	require.Len(t, paritionedRows, 2)
 	require.Len(t, paritionedRows[1], 3)
 	// We must ensure that the sequence is not broken.
-	require.LessOrEqual(t, paritionedRows[1][0].CommitTs, paritionedRows[1][1].CommitTs, paritionedRows[1][2].CommitTs)
+	require.LessOrEqual(
+		t,
+		paritionedRows[1][0].CommitTs, paritionedRows[1][1].CommitTs,
+		paritionedRows[1][2].CommitTs,
+	)
 	require.Len(t, paritionedRows[2], 1)
 }