From 41a2a87a910598c1174e72c832b6f73deb8b3253 Mon Sep 17 00:00:00 2001 From: dengyangguang <41094915+dengyangguang@users.noreply.github.com> Date: Fri, 23 Dec 2022 16:13:42 +0800 Subject: [PATCH] =?UTF-8?q?fix=20issue=20#4267=20old=E5=92=8Cdata=E9=95=BF?= =?UTF-8?q?=E5=BA=A6=E4=B8=8D=E4=B8=80=E6=A0=B7=E8=80=8C=E4=BA=A7=E7=94=9F?= =?UTF-8?q?=E7=9A=84=E4=B8=8B=E6=A0=87=E8=B6=8A=E7=95=8C=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=20(#4504)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/connector/core/producer/MQMessageUtils.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java index 1a15a8fa..fcbe69ad 100644 --- a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java +++ b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java @@ -433,9 +433,7 @@ public class MQMessageUtils { } } // update操作将记录修改前的值 - if (!rowOld.isEmpty()) { - old.add(rowOld); - } + old.add(rowOld); } } if (!sqlType.isEmpty()) {