diff --git a/source/src/main/java/io/mycat/mycat2/beans/MySQLRepBean.java b/source/src/main/java/io/mycat/mycat2/beans/MySQLRepBean.java index 33b830c..63c7bc4 100644 --- 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;