From e4726972de7f4255b7d4463d65769934181d27a4 Mon Sep 17 00:00:00 2001 From: dengliming Date: Thu, 20 Aug 2020 21:18:51 +0800 Subject: [PATCH] refactor: delete duplicate code (#2748) --- .../alibaba/otter/canal/client/adapter/support/MessageUtil.java | 1 - .../com/alibaba/otter/canal/connector/core/util/MessageUtil.java | 1 - 2 files changed, 2 deletions(-) diff --git a/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/MessageUtil.java b/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/MessageUtil.java index d0b42951..8d12debc 100644 --- a/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/MessageUtil.java +++ b/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/MessageUtil.java @@ -38,7 +38,6 @@ public class MessageUtil { CanalEntry.EventType eventType = rowChange.getEventType(); final Dml dml = new Dml(); - dml.setIsDdl(rowChange.getIsDdl()); dml.setDestination(destination); dml.setGroupId(groupId); dml.setDatabase(entry.getHeader().getSchemaName()); diff --git a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/MessageUtil.java b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/MessageUtil.java index 1096739b..160f04e3 100644 --- a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/MessageUtil.java +++ b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/MessageUtil.java @@ -42,7 +42,6 @@ public class MessageUtil { CanalEntry.EventType eventType = rowChange.getEventType(); final CommonMessage msg = new CommonMessage(); - msg.setIsDdl(rowChange.getIsDdl()); msg.setDatabase(entry.getHeader().getSchemaName()); msg.setTable(entry.getHeader().getTableName()); msg.setType(eventType.toString());