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());