Browse Source

IOException限制retry次数,超过次数后跳过binlog解析

Yishun.Chen 9 years ago
parent
commit
63b3c4ab54

+ 6 - 0
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;