From fedc07352b2c7617f65178d152553b83049a93aa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=83=E9=94=8B?= Date: Tue, 5 Jun 2018 14:59:33 +0800 Subject: [PATCH] fixed issue #662 --- .../alibaba/otter/canal/client/impl/SimpleCanalConnector.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java b/client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java index a6eabed1..0b870c17 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java @@ -457,8 +457,10 @@ public class SimpleCanalConnector implements CanalConnector { } running = true; - mutex.get();// 阻塞等待 + } else { + // 单机模式直接设置为running + running = true; } } catch (InterruptedException e) { Thread.currentThread().interrupt();