try fix conflicts.

pingcap · Jan 13, 2022 · a39f2df · a39f2df
1 parent 877a689
commit a39f2df
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 14 deletions.
diff --git a/cdc/sink/codec/canal.go b/cdc/sink/codec/canal.go
@@ -392,12 +392,8 @@ func (d *CanalEventBatchEncoder) Build() []*MQMessage {
 	if err != nil {
 		log.Panic("Error when serializing Canal packet", zap.Error(err))
 	}
-<<<<<<< HEAD
 	ret := NewMQMessage(ProtocolCanal, nil, value, 0, model.MqMessageTypeRow, nil, nil)
-=======
-	ret := NewMQMessage(config.ProtocolCanal, nil, value, 0, model.MqMessageTypeRow, nil, nil)
 	ret.SetRowsCount(rowCount)
->>>>>>> fc70dbde8 (metrics(cdc): fix mq sink write row count metrics. (#4192))
 	d.messages.Reset()
 	d.resetPacket()
 	return []*MQMessage{ret}

diff --git a/cdc/sink/codec/canal_flat.go b/cdc/sink/codec/canal_flat.go
@@ -237,13 +237,7 @@ func (c *CanalFlatEventBatchEncoder) Build() []*MQMessage {
 			log.Panic("CanalFlatEventBatchEncoder", zap.Error(err))
 			return nil
 		}
-<<<<<<< HEAD
 		ret[i] = NewMQMessage(ProtocolCanalJSON, nil, value, msg.tikvTs, model.MqMessageTypeRow, &msg.Schema, &msg.Table)
-=======
-		m := NewMQMessage(config.ProtocolCanalJSON, nil, value, msg.getTikvTs(), model.MqMessageTypeRow, msg.getSchema(), msg.getTable())
-		m.IncRowsCount()
-		ret[i] = m
->>>>>>> fc70dbde8 (metrics(cdc): fix mq sink write row count metrics. (#4192))
 	}
 	c.resolvedBuf = c.resolvedBuf[0:0]
 	return ret

diff --git a/cdc/sink/codec/maxwell.go b/cdc/sink/codec/maxwell.go
@@ -296,12 +296,8 @@ func (d *MaxwellEventBatchEncoder) Build() []*MQMessage {
 		return nil
 	}
 
-<<<<<<< HEAD
 	ret := NewMQMessage(ProtocolMaxwell, d.keyBuf.Bytes(), d.valueBuf.Bytes(), 0, model.MqMessageTypeRow, nil, nil)
-=======
-	ret := NewMQMessage(config.ProtocolMaxwell, d.keyBuf.Bytes(), d.valueBuf.Bytes(), 0, model.MqMessageTypeRow, nil, nil)
 	ret.SetRowsCount(d.batchSize)
->>>>>>> fc70dbde8 (metrics(cdc): fix mq sink write row count metrics. (#4192))
 	d.Reset()
 	return []*MQMessage{ret}
 }