From 6b9c1305ff4d6de66d3575ab89a377be74be064b Mon Sep 17 00:00:00 2001
From: zhangyukun <helloworld_zyk@163.com>
Date: Wed, 24 Feb 2016 21:18:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0dml=E8=BF=87=E6=BB=A4?=
 =?UTF-8?q?=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修复parseRowsEvent方法中没有dml过滤的判断而导致dml操作的数据总是会输出到store中的bug
---
 .../canal/parse/inbound/mysql/dbsync/LogEventConvert.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java
index cc092d46..41d39e27 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java
@@ -305,6 +305,9 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar
     }
 
     private Entry parseRowsEvent(RowsLogEvent event) {
+        if (filterQueryDml) {
+            return null;
+        }
         try {
             TableMapLogEvent table = event.getTable();
             if (table == null) {