From ecba855bf967fb9a374bea3d8872c1dacfa168f5 Mon Sep 17 00:00:00 2001
From: "Yishun.Chen" <chenyishun>
Date: Tue, 3 May 2016 16:30:01 +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

---
 .../canal/parse/inbound/mysql/LocalBinlogEventParser.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java
index 2317c0c2..61f4a53b 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java
@@ -1,5 +1,7 @@
 package com.alibaba.otter.canal.parse.inbound.mysql;
 
+import java.io.IOException;
+
 import org.apache.commons.lang.StringUtils;
 
 import com.alibaba.otter.canal.parse.CanalEventParser;
@@ -52,6 +54,12 @@ public class LocalBinlogEventParser extends AbstractMysqlEventParser implements
 
         return connection;
     }
+    
+    @Override
+	protected EntryPosition findEndPosition(ErosaConnection connection) throws IOException {
+		// TODO 没有实现
+		return findStartPosition(connection);
+	}
 
     @Override
     protected EntryPosition findStartPosition(ErosaConnection connection) {