diff --git a/escheduler-api/src/main/java/cn/escheduler/api/enums/Status.java b/escheduler-api/src/main/java/cn/escheduler/api/enums/Status.java index 265dac3d227ae94ba16299f83bcd2db133c2d959..1704aa238744360f620d91be2bbb79c56169efff 100644 --- a/escheduler-api/src/main/java/cn/escheduler/api/enums/Status.java +++ b/escheduler-api/src/main/java/cn/escheduler/api/enums/Status.java @@ -190,8 +190,14 @@ public enum Status { PROCESS_NODE_HAS_CYCLE(50019,"process node has cycle"), PROCESS_NODE_S_PARAMETER_INVALID(50020,"process node %s parameter invalid"), - HDFS_NOT_STARTUP(60001,"hdfs not startup"), + + /** + * for monitor + */ + QUERY_DATABASE_STATE_ERROR(70001,"query database state error"), + QUERY_ZOOKEEPER_STATE_ERROR(70002,"query zookeeper state error"), + ; private int code; diff --git a/escheduler-common/src/main/java/cn/escheduler/common/Constants.java b/escheduler-common/src/main/java/cn/escheduler/common/Constants.java index e0e0c399e9ea32524a5bbb3f87e16c4ba6783c7e..6b6df52eca196f1cfb965729ed7af3c432ec8053 100644 --- a/escheduler-common/src/main/java/cn/escheduler/common/Constants.java +++ b/escheduler-common/src/main/java/cn/escheduler/common/Constants.java @@ -453,7 +453,7 @@ public final class Constants { /** * task record configuration path */ - public static final String TASK_RECORD_PROPERTIES_PATH = "dao/data_source.properties"; + public static final String DATA_SOURCE_PROPERTIES = "dao/data_source.properties"; public static final String TASK_RECORD_URL = "task.record.datasource.url"; diff --git a/escheduler-common/src/main/java/cn/escheduler/common/zk/AbstractZKClient.java b/escheduler-common/src/main/java/cn/escheduler/common/zk/AbstractZKClient.java index 730b2f1eb8bbc5072ae08390faa7c773d0f62137..177669b43c3326d36a485bdf1faca905cbaa8962 100644 --- a/escheduler-common/src/main/java/cn/escheduler/common/zk/AbstractZKClient.java +++ b/escheduler-common/src/main/java/cn/escheduler/common/zk/AbstractZKClient.java @@ -87,15 +87,6 @@ public abstract class AbstractZKClient { public AbstractZKClient() { - StringBuilder sb = new StringBuilder(); - String[] zookeeperParamslist = conf.getStringArray(Constants.ZOOKEEPER_QUORUM); - for (String param : zookeeperParamslist) { - sb.append(param).append(Constants.COMMA); - } - - if(sb.length() > 0){ - sb.deleteCharAt(sb.length() - 1); - } // retry strategy RetryPolicy retryPolicy = new ExponentialBackoffRetry( @@ -105,7 +96,7 @@ public abstract class AbstractZKClient { try{ // crate zookeeper client zkClient = CuratorFrameworkFactory.builder() - .connectString(sb.toString()) + .connectString(getZookeeperQuorum()) .retryPolicy(retryPolicy) .sessionTimeoutMs(1000 * Integer.parseInt(conf.getString(Constants.ZOOKEEPER_SESSION_TIMEOUT))) .connectionTimeoutMs(1000 * Integer.parseInt(conf.getString(Constants.ZOOKEEPER_CONNECTION_TIMEOUT))) @@ -327,6 +318,24 @@ public abstract class AbstractZKClient { return childrenList.size(); } + /** + * + * @return zookeeper quorum + */ + public static String getZookeeperQuorum(){ + StringBuilder sb = new StringBuilder(); + String[] zookeeperParamslist = conf.getStringArray(Constants.ZOOKEEPER_QUORUM); + for (String param : zookeeperParamslist) { + sb.append(param).append(Constants.COMMA); + } + + if(sb.length() > 0){ + sb.deleteCharAt(sb.length() - 1); + } + + return sb.toString(); + } + @Override public String toString() { return "AbstractZKClient{" + diff --git a/escheduler-dao/src/main/java/cn/escheduler/dao/MonitorDBDao.java b/escheduler-dao/src/main/java/cn/escheduler/dao/MonitorDBDao.java index 54c55699b396cd48b518194efaf1a5e279a7cc5b..ef93a072962c44131904988366b7bd232360e82d 100644 --- a/escheduler-dao/src/main/java/cn/escheduler/dao/MonitorDBDao.java +++ b/escheduler-dao/src/main/java/cn/escheduler/dao/MonitorDBDao.java @@ -45,7 +45,7 @@ public class MonitorDBDao { static { try { - conf = new PropertiesConfiguration(Constants.DataSource_PROPERTIES_PATH); + conf = new PropertiesConfiguration(Constants.DATA_SOURCE_PROPERTIES); }catch (ConfigurationException e){ logger.error("load configuration excetpion",e); System.exit(1); diff --git a/escheduler-dao/src/main/java/cn/escheduler/dao/TaskRecordDao.java b/escheduler-dao/src/main/java/cn/escheduler/dao/TaskRecordDao.java index ebc206f9ac6205a6764538ddac64834c7aaf8322..e74ea8c483f3dd5176faf508b82c6129dc4f1a70 100644 --- a/escheduler-dao/src/main/java/cn/escheduler/dao/TaskRecordDao.java +++ b/escheduler-dao/src/main/java/cn/escheduler/dao/TaskRecordDao.java @@ -46,7 +46,7 @@ public class TaskRecordDao { static { try { - conf = new PropertiesConfiguration(Constants.TASK_RECORD_PROPERTIES_PATH); + conf = new PropertiesConfiguration(Constants.DATA_SOURCE_PROPERTIES); }catch (ConfigurationException e){ logger.error("load configuration excetpion",e); System.exit(1);