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 68eb5062..b7270b5a 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 @@ -934,4 +934,7 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE this.rdsOssMode = rdsOssMode; } + public void setDumpErrorCount(int dumpErrorCount) { + this.dumpErrorCount = dumpErrorCount; + } } diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsBinlogEventParserProxy.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsBinlogEventParserProxy.java index f3a220b0..817d895f 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsBinlogEventParserProxy.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsBinlogEventParserProxy.java @@ -12,11 +12,11 @@ import com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser; /** * aliyun rds的binlog parser支持 - * + * *
  * 注意点:aliyun的binlog会有定期清理并备份到oss上, 这里实现了一份自动下载oss+rds binlog的机制
  * 
- * + * * @author chengjin.lyf on 2018/7/20 上午10:52 * @since 1.0.25 */ @@ -88,6 +88,9 @@ public class RdsBinlogEventParserProxy extends MysqlEventParser { @Override public void run() { rdsLocalBinlogEventParser.stop(); + // empty the dump error count,or will go into local binlog mode again,with error + // position,never get out,fixed by bucketli + RdsBinlogEventParserProxy.this.setDumpErrorCount(0); RdsBinlogEventParserProxy.this.start(); } });