From 63b3c4ab543c5b54b359ad20c396b9e7544d9856 Mon Sep 17 00:00:00 2001
From: "Yishun.Chen" <chenyishun>
Date: Tue, 3 May 2016 16:30:38 +0800
Subject: [PATCH] =?UTF-8?q?IOException=E9=99=90=E5=88=B6retry=E6=AC=A1?=
 =?UTF-8?q?=E6=95=B0=EF=BC=8C=E8=B6=85=E8=BF=87=E6=AC=A1=E6=95=B0=E5=90=8E?=
 =?UTF-8?q?=E8=B7=B3=E8=BF=87binlog=E8=A7=A3=E6=9E=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../otter/canal/parse/inbound/mysql/MysqlEventParser.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
index d63f76fb..6deea962 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
@@ -322,6 +322,12 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
         }
         return startPosition;
     }
+    
+	protected EntryPosition findEndPosition(ErosaConnection connection) throws IOException {
+		MysqlConnection mysqlConnection = (MysqlConnection) connection;
+		 EntryPosition endPosition = findEndPosition(mysqlConnection);
+		return endPosition;
+	}
 
     protected EntryPosition findStartPositionInternal(ErosaConnection connection) {
         MysqlConnection mysqlConnection = (MysqlConnection) connection;