Commit 2861e551 authored by wenmo's avatar wenmo

集群配置测试优化

parent 3072dc0e
......@@ -218,16 +218,20 @@ public abstract class YarnGateway extends AbstractGateway {
try {
initConfig();
}catch (Exception e){
logger.error("测试 Flink 配置失败:"+e.getMessage());
return TestResult.fail("测试 Flink 配置失败:"+e.getMessage());
}
try {
initYarnClient();
if(yarnClient.isInState(Service.STATE.STARTED)){
logger.info("配置连接测试成功");
return TestResult.success();
}else{
logger.error("该配置无对应 Yarn 集群存在");
return TestResult.fail("该配置无对应 Yarn 集群存在");
}
}catch (Exception e){
logger.error("测试 Yarn 配置失败:"+e.getMessage());
return TestResult.fail("测试 Yarn 配置失败:"+e.getMessage());
}
}
......
......@@ -63,8 +63,8 @@ const ClusterConfigurationForm: React.FC<ClusterConfigurationFormProps> = (props
enabled:fieldsValue.enabled,
configJson:JSON.stringify(getConfig(fieldsValue)),
};
setFormVals({...formVals, ...formValues});
handleSubmit({...formVals, ...formValues});
setFormVals(formValues);
handleSubmit(formValues);
};
const renderContent = (formVals) => {
......@@ -204,10 +204,18 @@ const ClusterConfigurationForm: React.FC<ClusterConfigurationFormProps> = (props
);
};
const testForm = ()=>{
const fieldsValue = form.validateFields();
setFormVals({...formVals, ...fieldsValue});
testClusterConfigurationConnect(formVals);
const testForm = async ()=>{
const fieldsValue = await form.validateFields();
let formValues = {
name:fieldsValue.name,
alias:fieldsValue.alias,
type:fieldsValue.type,
note:fieldsValue.note,
enabled:fieldsValue.enabled,
configJson:JSON.stringify(getConfig(fieldsValue)),
};
setFormVals(formValues);
testClusterConfigurationConnect(formValues);
};
const renderFooter = () => {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment