From aa8ea96572d7b012d61602f261a235c7e9b1b245 Mon Sep 17 00:00:00 2001 From: agapple Date: Fri, 26 Aug 2016 18:25:52 +0800 Subject: [PATCH] fixed issue #195 --- .../com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java b/meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java index 46b7671e..f3d8c5d0 100644 --- a/meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java +++ b/meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java @@ -142,8 +142,8 @@ public class PeriodMixedMetaManager extends MemoryMetaManager implements CanalMe } public void updateCursor(ClientIdentity clientIdentity, Position position) throws CanalMetaManagerException { - updateCursorTasks.add(clientIdentity);// 添加到任务队列中进行触发 super.updateCursor(clientIdentity, position); + updateCursorTasks.add(clientIdentity);// 添加到任务队列中进行触发 } public Position getCursor(ClientIdentity clientIdentity) throws CanalMetaManagerException {