diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java
index 5b697eb9..f36aa726 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java
@@ -64,7 +64,10 @@ public class MemoryTableMeta implements TableMetaTSDB {
}
try {
- repository.console(ddl);
+ // druid暂时flush privileges语法解析有问题
+ if (!StringUtils.startsWithIgnoreCase(StringUtils.trim(ddl), "flush")) {
+ repository.console(ddl);
+ }
} catch (Throwable e) {
logger.warn("parse faield : " + ddl, e);
}
diff --git a/pom.xml b/pom.xml
index 5557c718..89d68cbe 100644
--- a/pom.xml
+++ b/pom.xml
@@ -254,7 +254,7 @@
com.alibaba
druid
- 1.1.5
+ 1.1.6