in dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-zookeeper/src/main/java/org/apache/dolphinscheduler/plugin/registry/zookeeper/ZookeeperRegistryProperties.java [54:83]
public void validate(Object target, Errors errors) {
ZookeeperRegistryProperties zookeeperRegistryProperties = (ZookeeperRegistryProperties) target;
if (zookeeperRegistryProperties.getZookeeper() == null) {
errors.rejectValue("zookeeper", "zookeeper", "zookeeper properties is required");
}
ZookeeperProperties zookeeper = zookeeperRegistryProperties.getZookeeper();
if (StringUtils.isEmpty(zookeeper.getNamespace())) {
errors.rejectValue("zookeeper.namespace", "", "zookeeper.namespace cannot be null");
}
if (StringUtils.isEmpty(zookeeper.getConnectString())) {
errors.rejectValue("zookeeper.connectString", "", "zookeeper.connectString cannot be null");
}
if (zookeeper.getRetryPolicy() == null) {
errors.rejectValue("zookeeper.retryPolicy", "", "zookeeper.retryPolicy cannot be null");
}
if (zookeeper.getSessionTimeout() == null || zookeeper.getSessionTimeout().isZero()
|| zookeeper.getSessionTimeout().isNegative()) {
errors.rejectValue("zookeeper.sessionTimeout", "", "zookeeper.sessionTimeout should be positive");
}
if (zookeeper.getConnectionTimeout() == null || zookeeper.getConnectionTimeout().isZero()
|| zookeeper.getConnectionTimeout().isNegative()) {
errors.rejectValue("zookeeper.connectionTimeout", "", "zookeeper.connectionTimeout should be positive");
}
if (zookeeper.getBlockUntilConnected() == null || zookeeper.getBlockUntilConnected().isZero()
|| zookeeper.getBlockUntilConnected().isNegative()) {
errors.rejectValue("zookeeper.blockUntilConnected", "", "zookeeper.blockUntilConnected should be positive");
}
printConfig();
}