Compare commits

...

1 Commits

Author SHA1 Message Date
bucketli
7ac605242e fix(canal):fix endless local binlog mode with exception. 2020-02-27 17:56:10 +08:00
2 changed files with 8 additions and 2 deletions

View File

@@ -934,4 +934,7 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
this.rdsOssMode = rdsOssMode; this.rdsOssMode = rdsOssMode;
} }
public void setDumpErrorCount(int dumpErrorCount) {
this.dumpErrorCount = dumpErrorCount;
}
} }

View File

@@ -12,11 +12,11 @@ import com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser;
/** /**
* aliyun rds的binlog parser支持 * aliyun rds的binlog parser支持
* *
* <pre> * <pre>
* 注意点:aliyun的binlog会有定期清理并备份到oss上, 这里实现了一份自动下载oss+rds binlog的机制 * 注意点:aliyun的binlog会有定期清理并备份到oss上, 这里实现了一份自动下载oss+rds binlog的机制
* </pre> * </pre>
* *
* @author chengjin.lyf on 2018/7/20 上午10:52 * @author chengjin.lyf on 2018/7/20 上午10:52
* @since 1.0.25 * @since 1.0.25
*/ */
@@ -88,6 +88,9 @@ public class RdsBinlogEventParserProxy extends MysqlEventParser {
@Override @Override
public void run() { public void run() {
rdsLocalBinlogEventParser.stop(); 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(); RdsBinlogEventParserProxy.this.start();
} }
}); });