mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Compare commits
1 Commits
canal-1.1.
...
bugfix_end
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7ac605242e |
@@ -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;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user