chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
Yishun.Chen
2016-05-03 16:30:01 +08:00
parent b599846470
commit ecba855bf9
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java
View File

@@ -1,5 +1,7 @@
package com.alibaba.otter.canal.parse.inbound.mysql; package com.alibaba.otter.canal.parse.inbound.mysql;
import java.io.IOException;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import com.alibaba.otter.canal.parse.CanalEventParser; import com.alibaba.otter.canal.parse.CanalEventParser;
@@ -53,6 +55,12 @@ public class LocalBinlogEventParser extends AbstractMysqlEventParser implements
return connection; return connection;
} }
@Override
protected EntryPosition findEndPosition(ErosaConnection connection) throws IOException {
// TODO 没有实现
return findStartPosition(connection);
}
@Override @Override
protected EntryPosition findStartPosition(ErosaConnection connection) { protected EntryPosition findStartPosition(ErosaConnection connection) {
// 处理逻辑 // 处理逻辑