From 7eb6fb3e8a263dee9fc93ce004900e665485914f Mon Sep 17 00:00:00 2001 From: spccold Date: Sun, 6 May 2018 21:50:34 +0800 Subject: [PATCH] fix CanalInstanceWithManager#doInitEventParser bug --- .../otter/canal/instance/manager/CanalInstanceWithManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java index 53196169..bca5ba13 100644 --- a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java +++ b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java @@ -263,7 +263,7 @@ public class CanalInstanceWithManager extends AbstractCanalInstance { mysqlEventParser.setMasterPosition(masterPosition); if (parameters.getPositions().size() > 1) { - EntryPosition standbyPosition = JsonUtils.unmarshalFromString(parameters.getPositions().get(0), + EntryPosition standbyPosition = JsonUtils.unmarshalFromString(parameters.getPositions().get(1), EntryPosition.class); mysqlEventParser.setStandbyPosition(standbyPosition); }