Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7ac605242e |
@@ -934,4 +934,7 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
|
||||
this.rdsOssMode = rdsOssMode;
|
||||
}
|
||||
|
||||
public void setDumpErrorCount(int dumpErrorCount) {
|
||||
this.dumpErrorCount = dumpErrorCount;
|
||||
}
|
||||
}
|
||||
|
||||
+5
-2
@@ -12,11 +12,11 @@ import com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser;
|
||||
|
||||
/**
|
||||
* aliyun rds的binlog parser支持
|
||||
*
|
||||
*
|
||||
* <pre>
|
||||
* 注意点:aliyun的binlog会有定期清理并备份到oss上, 这里实现了一份自动下载oss+rds binlog的机制
|
||||
* </pre>
|
||||
*
|
||||
*
|
||||
* @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();
|
||||
}
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user