From 8cadd585c6af6f22036393614c66e6c45f80ddee Mon Sep 17 00:00:00 2001
From: jiucheng <jiucheng.org@gmail.com>
Date: Wed, 20 Feb 2019 09:49:15 +0800
Subject: [PATCH] =?UTF-8?q?adapter=20rdb=E6=97=A0=E6=B3=95=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5ddl=E6=9B=B4=E6=96=B0=E9=97=AE=E9=A2=98=E4=BF=AE?=
 =?UTF-8?q?=E6=AD=A3=20adapter/support/MessageUtil.java?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../alibaba/otter/canal/client/adapter/support/MessageUtil.java  | 1 +
 1 file changed, 1 insertion(+)

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 93ca987b..51e6a1b4 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
@@ -37,6 +37,7 @@ 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());