From 01ef15223cafa277ed7f0292ce97781abaf0b73d Mon Sep 17 00:00:00 2001
From: agapple <jianghang.loujh@alibaba-inc.com>
Date: Mon, 4 Dec 2017 13:19:58 +0800
Subject: [PATCH] fixed issue #415, ignore flush privileges

---
 .../canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java      | 5 ++++-
 pom.xml                                                      | 2 +-
 2 files changed, 5 insertions(+), 2 deletions(-)

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 @@
             <dependency>
                 <groupId>com.alibaba</groupId>
                 <artifactId>druid</artifactId>
-                <version>1.1.5</version>
+                <version>1.1.6</version>
             </dependency>
             <!-- log -->
             <dependency>