fix(project): fix isDdl judge #2599

2020-02-28 14:21:12 +08:00
parent bd56438eca
commit c21c18458b
1 changed files with 1 additions and 1 deletions
@@ -275,7 +275,7 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar

            Header header = createHeader(event.getHeader(), schemaName, tableName, type);
            RowChange.Builder rowChangeBuider = RowChange.newBuilder();
-            if (type != EventType.QUERY && !isDml) {
+            if (type == EventType.QUERY && !isDml) {
                rowChangeBuider.setIsDdl(true);
            }
            rowChangeBuider.setSql(queryString);