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