From f6c2eb8963c510dc194d636942253ba06e281d59 Mon Sep 17 00:00:00 2001
From: agapple <jianghang.loujh@alibaba-inc.com>
Date: Thu, 11 May 2017 14:05:58 +0800
Subject: [PATCH] fixed issue #296 , NPE

---
 .../otter/canal/client/impl/ClusterCanalConnector.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java b/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java
index d062b4ff..9fd1ca10 100644
--- a/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java
+++ b/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java
@@ -108,7 +108,7 @@ public class ClusterCanalConnector implements CanalConnector {
                 return;
             } catch (Throwable t) {
                 logger.warn("something goes wrong when subscribing from server:{}\n{}",
-                    currentConnector.getAddress(),
+                    currentConnector != null ? currentConnector.getAddress() : "null",
                     ExceptionUtils.getFullStackTrace(t));
                 times++;
                 restart();
@@ -127,7 +127,7 @@ public class ClusterCanalConnector implements CanalConnector {
                 return;
             } catch (Throwable t) {
                 logger.warn("something goes wrong when unsubscribing from server:{}\n{}",
-                    currentConnector.getAddress(),
+                    currentConnector != null ? currentConnector.getAddress() : "null",
                     ExceptionUtils.getFullStackTrace(t));
                 times++;
                 restart();
@@ -145,7 +145,7 @@ public class ClusterCanalConnector implements CanalConnector {
                 return msg;
             } catch (Throwable t) {
                 logger.warn("something goes wrong when getting data from server:{}\n{}",
-                    currentConnector.getAddress(),
+                    currentConnector != null ? currentConnector.getAddress() : "null",
                     ExceptionUtils.getFullStackTrace(t));
                 times++;
                 restart();
@@ -163,7 +163,7 @@ public class ClusterCanalConnector implements CanalConnector {
                 return msg;
             } catch (Throwable t) {
                 logger.warn("something goes wrong when getting data from server:{}\n{}",
-                    currentConnector.getAddress(),
+                    currentConnector != null ? currentConnector.getAddress() : "null",
                     ExceptionUtils.getFullStackTrace(t));
                 times++;
                 restart();