diff --git a/pkg/sink/codec/canal/canal_json_decoder.go b/pkg/sink/codec/canal/canal_json_decoder.go
index add985a3d35..18a1116e98c 100644
--- a/pkg/sink/codec/canal/canal_json_decoder.go
+++ b/pkg/sink/codec/canal/canal_json_decoder.go
@@ -81,7 +81,6 @@ func (b *bufferedJSONDecoder) Bytes() []byte {
 
 // batchDecoder decodes the byte into the original message.
 type batchDecoder struct {
-	// data    []byte
 	msg     canalJSONMessageInterface
 	decoder *bufferedJSONDecoder