diff --git a/node/etl/src/main/java/com/alibaba/otter/node/etl/common/db/utils/DdlUtils.java b/node/etl/src/main/java/com/alibaba/otter/node/etl/common/db/utils/DdlUtils.java

index 2f9d2e1..35e1fcb 100644

--- a/node/etl/src/main/java/com/alibaba/otter/node/etl/common/db/utils/DdlUtils.java

+++ b/node/etl/src/main/java/com/alibaba/otter/node/etl/common/db/utils/DdlUtils.java

@@ -16,6 +16,7 @@ import com.alibaba.druid.sql.dialect.mysql.ast.statement.MySqlCreateTableStateme

 import com.alibaba.druid.sql.dialect.mysql.ast.statement.MySqlRenameTableStatement;

 import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;

 import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlOutputVisitor;

+import com.alibaba.druid.sql.ast.statement.SQLAlterTableReOrganizePartition;

 

 

         // 处理下DDL操作

         if (eventType.isQuery()) {

             // 直接忽略query事件

diff --git a/shared/etl/src/main/java/com/alibaba/otter/shared/etl/model/EventType.java b/shared/etl/src/main/java/com/alibaba/otter/shared/etl/model/EventType.java

index f62c23d..be10eba 100644

--- a/shared/etl/src/main/java/com/alibaba/otter/shared/etl/model/EventType.java

+++ b/shared/etl/src/main/java/com/alibaba/otter/shared/etl/model/EventType.java

@@ -76,7 +76,17 @@ public enum EventType {

     

-    DINDEX("DI");

+    DINDEX("DI"),

+

+   

+    XACOMMIT("XC"),

+

+   

+    XAROLLBACK("XR");

 

     private String value;

 

@@ -128,6 +138,13 @@ public enum EventType {

         return this.equals(EventType.DINDEX);

     }

 

+    public boolean isXaCommit() {

+        return this.equals(EventType.XACOMMIT);

+    }

+    public boolean isXaRollBack() {

+        return this.equals(EventType.XAROLLBACK);

+    }

+

     public boolean isDdl() {

         return isCreate() || isAlter() || isErase() || isTruncate() || isRename() || isCindex() || isDindex();

     }

@@ -136,6 +153,10 @@ public enum EventType {

         return isInsert() || isUpdate() || isDelete();

     }

 

+    public boolean isXaHandle() {

+        return isXaCommit() || isXaRollBack();

+    }

+

     public static EventType valuesOf(String value) {

         EventType[] eventTypes = values();

         for (EventType eventType : eventTypes) {