修复，集群从节点无法联通的问题

zwyqz · Sep 23, 2017 · 2fdd7b5 · 2fdd7b5
1 parent b218c17
commit 2fdd7b5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/source/src/main/java/io/mycat/mycat2/beans/MySQLRepBean.java b/source/src/main/java/io/mycat/mycat2/beans/MySQLRepBean.java
@@ -274,7 +274,7 @@ public int getDataSourceInitStatus(){
 		int initstatus = DBHeartbeat.OK_STATUS;
 		MyCluster myCluster = ProxyRuntime.INSTANCE.getMyCLuster();
 
-		if(myCluster.getMyLeader()==myCluster.getMyNode()){
+		if(myCluster==null||myCluster.getMyLeader()==myCluster.getMyNode()){
 			initstatus = DBHeartbeat.INIT_STATUS;
 		}
 		return initstatus;