ticdc(sink): remove useless code

pingcap · Feb 20, 2022 · 79c59b6 · 79c59b6
1 parent 8308d3a
commit 79c59b6
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/cdc/sink/mq.go b/cdc/sink/mq.go
@@ -59,7 +59,6 @@ type mqSink struct {
 	filter         *filter.Filter
 	protocol       config.Protocol
 
-	partitionNum         int32
 	flushWorker          *flushWorker
 	tableCheckpointTsMap sync.Map
 	resolvedBuffer       chan resolvedTsEvent
@@ -115,7 +114,6 @@ func newMqSink(
 		encoderBuilder: encoderBuilder,
 		filter:         filter,
 		protocol:       protocol,
-		partitionNum:   partitionNum,
 		flushWorker:    flushWorker,
 		resolvedBuffer: make(chan resolvedTsEvent, defaultResolvedTsEventBufferSize),
 		statistics:     NewStatistics(ctx, "MQ"),