diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/enums/Status.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/enums/Status.java index daf7026e782e..51bb41cb7894 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/enums/Status.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/enums/Status.java @@ -261,6 +261,8 @@ public enum Status { QUERY_TASK_INSTANCE_ERROR(10205, "query task instance error", "查询任务实例错误"), EXECUTE_NOT_DEFINE_TASK(10206, "please save and try again", "请先保存后再执行"), + TASK_DEFINITION_INVALID(10207, "Task definition validation failed, please check the configuration", + "任务定义校验失败,请检查配置"), DELETE_QUEUE_BY_ID_ERROR(10307, "delete queue by id error", "删除队列错误"), DELETE_QUEUE_BY_ID_FAIL_USERS(10308, "delete queue by id fail, for there are {0} users using it", @@ -426,6 +428,7 @@ public enum Status { TASK_PARALLELISM_PARAMS_ERROR(50080, "task parallelism parameter is not valid", "任务并行度参数无效"), TASK_COMPLEMENT_DATA_DATE_ERROR(50081, "The range of date for complementing date is not valid", "补数选择的日期范围无效"), + WORKFLOW_DEFINE_ILLEGAL_ARG(50082, "create workflow definition illegal {0}", "创建工作流非法 {0}"), HDFS_NOT_STARTUP(60001, "hdfs not startup", "hdfs未启用"), STORAGE_NOT_STARTUP(60002, "storage not startup", "存储未启用"), diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowDefinitionServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowDefinitionServiceImpl.java index 7fe3d00a511e..cddf5d0f0fa8 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowDefinitionServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowDefinitionServiceImpl.java @@ -487,7 +487,7 @@ private List generateTaskDefinitionList(String taskDefinition throw ex; } catch (Exception e) { log.error("Generate task definition list failed, meet an unknown exception", e); - throw new ServiceException(Status.REQUEST_PARAMS_NOT_VALID_ERROR); + throw new ServiceException(Status.TASK_DEFINITION_INVALID); } }