mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
fix CanalInstanceWithManager#doInitEventParser bug
This commit is contained in:
@@ -263,7 +263,7 @@ public class CanalInstanceWithManager extends AbstractCanalInstance {
|
|||||||
mysqlEventParser.setMasterPosition(masterPosition);
|
mysqlEventParser.setMasterPosition(masterPosition);
|
||||||
|
|
||||||
if (parameters.getPositions().size() > 1) {
|
if (parameters.getPositions().size() > 1) {
|
||||||
EntryPosition standbyPosition = JsonUtils.unmarshalFromString(parameters.getPositions().get(0),
|
EntryPosition standbyPosition = JsonUtils.unmarshalFromString(parameters.getPositions().get(1),
|
||||||
EntryPosition.class);
|
EntryPosition.class);
|
||||||
mysqlEventParser.setStandbyPosition(standbyPosition);
|
mysqlEventParser.setStandbyPosition(standbyPosition);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user