check if the message is empty.

pingcap · Oct 25, 2022 · f4754e1 · f4754e1
1 parent a8e341f
commit f4754e1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cdc/sink/mq/mq_flush_worker.go b/cdc/sink/mq/mq_flush_worker.go
@@ -261,6 +261,11 @@ func (w *flushWorker) nonBatchEncodeRun(ctx context.Context) error {
 				log.Warn("MQ sink flush worker channel closed")
 				return nil
 			}
+
+			if event.row == nil {
+				continue
+			}
+
 			err := w.encoder.AppendRowChangedEvent(ctx, event.key.Topic, event.row, nil)
 			if err != nil {
 				return err