diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ApplicationMessageStatus.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ApplicationMessageStatus.java index 69cd3772c1..690fa20850 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ApplicationMessageStatus.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ApplicationMessageStatus.java @@ -24,17 +24,17 @@ @Getter public enum ApplicationMessageStatus implements Status { - HANDLER_UPLOAD_FILE_IS_NULL_ERROR(10840, "File to upload can't be null. Upload file failed.", "要上传的文件不能为空，上传文件失败"), + HANDLER_UPLOAD_FILE_IS_NULL_ERROR(10840, "File to upload can''t be null. Upload file failed.", "要上传的文件不能为空，上传文件失败"), HANDLER_UPLOAD_FILE_TYPE_ILLEGAL_ERROR(10850, "Illegal file type, Only support standard jar or python files. Upload file failed.", "文件类型非法，仅支持标准jar或python文件 上传文件失败。"), APP_CREATE_FAILED(10860, "create application failed.", "创建应用程序失败"), - APP_ID_NOT_EXISTS_ERROR(10870, "The application id={0} can't be found.", "找不到应用程序 id={0}"), - APP_ID_NOT_EXISTS_REVOKE_FAILED(10880, "The application id={0} can't be found, revoke failed.", + APP_ID_NOT_EXISTS_ERROR(10870, "The application id={0} can''t be found.", "找不到应用程序 id={0}"), + APP_ID_NOT_EXISTS_REVOKE_FAILED(10880, "The application id={0} can''t be found, revoke failed.", "找不到应用程序 id={0}, 撤销失败"), - APP_EXECUTE_MODE_NOT_EXISTS_ERROR(10890, "ExecutionMode can't be null.", "执行模式不能为空"), - APP_EXECUTE_MODE_OPERATION_DISABLE_ERROR(10900, "The FlinkExecutionMode [{0}] can't [{1}]!", + APP_EXECUTE_MODE_NOT_EXISTS_ERROR(10890, "ExecutionMode can''t be null.", "执行模式不能为空"), + APP_EXECUTE_MODE_OPERATION_DISABLE_ERROR(10900, "The FlinkExecutionMode [{0}] can''t [{1}]!", "Flink执行模式[{0}]无法{1}！"), APP_NOT_EXISTS_ERROR(10920, "[StreamPark] {0} The application cannot be started repeatedly.", "[StreamPark] {0} 应用程序无法重复启动。"), @@ -52,22 +52,22 @@ public enum ApplicationMessageStatus implements Status { "作业无效，或者在作业运行时无法生成作业"), APP_JOB_EXECUTION_MODE_ILLEGALLY(10980, "Job executionMode must be kubernetes-session|kubernetes-application.", "Job 执行模式必须是 Kubernetes-session 或 Kubernetes-application"), - APP_PY_FLINK_FILE_IS_NULL(10990, "pyflink file can't be null, start application failed.", + APP_PY_FLINK_FILE_IS_NULL(10990, "pyflink file can''t be null, start application failed.", "PyFlink 文件不能为空，启动应用程序失败"), APP_PY_FLINK_FILE_TYPE_ILLEGALLY(101000, "pyflink format error, must be a \".py\" suffix, start application failed.", "PyFlink格式错误，必须是 \".py\" 后缀，启动应用程序失败"), APP_QUEUE_LABEL_IN_TEAM_ILLEGALLY(101010, - "Queue label [{0}] isn't available for teamId [{1}], please add it into the team first.", + "Queue label [{0}] isn''t available for teamId [{1}], please add it into the team first.", "队列标签 [{0}] 不适用于 teamId [{1}]，请先将其添加到团队中。"), APP_QUEUE_LABEL_IN_DATABASE_ILLEGALLY(101020, - "Queue label [{0}] isn't available in database, please add it first.", + "Queue label [{0}] isn''t available in database, please add it first.", "队列标签[{0}]在数据库中不可用，请先添加它"), APP_NAME_REPEAT_COPY_FAILED(101030, - "Application names can't be repeated, copy application failed.", + "Application names can''t be repeated, copy application failed.", "应用程序名称不能重复，复制应用程序失败。"), APP_FLINK_CLUSTER_NOT_RUNNING_UPDATE_FAILED(101040, diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/FlinkMessageStatus.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/FlinkMessageStatus.java index 7678bec375..b4f2ddbe66 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/FlinkMessageStatus.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/FlinkMessageStatus.java @@ -24,7 +24,7 @@ @Getter public enum FlinkMessageStatus implements Status { - FLINK_ENV_SQL_CLIENT_JAR_NOT_EXIST(10430, "[StreamPark] can't found streampark-flink-sqlclient jar in {0}", + FLINK_ENV_SQL_CLIENT_JAR_NOT_EXIST(10430, "[StreamPark] can''t found streampark-flink-sqlclient jar in {0}", "[StreamPark] 在{0}中找不到 streampark-flink-sqlclient jar"), FLINK_ENV_SQL_CLIENT_JAR_MULTIPLE_EXIST(10440, "[StreamPark] found multiple streampark-flink-sqlclient jar in {0}", "[StreamPark] 在 {0} 中发现多个 streampark-flink-sqlclient jar"), @@ -51,7 +51,7 @@ public enum FlinkMessageStatus implements Status { FLINK_CLUSTER_UNAVAILABLE(10540, "[StreamPark] The target cluster is unavailable, please check!, please check it", "[StreamPark] 目标集群不可用，请检查！"), - FLINK_CLUSTER_NOT_EXIST(10550, "[StreamPark] The flink cluster don't exist, please check it", + FLINK_CLUSTER_NOT_EXIST(10550, "[StreamPark] The flink cluster don''t exist, please check it", "[StreamPark] Flink 集群不存在，请检查"), FLINK_CLUSTER_NOT_RUNNING(10560, "[StreamPark] The flink cluster not running, please start it", "[StreamPark] Flink集群未运行，请启动它"), @@ -86,7 +86,7 @@ public enum FlinkMessageStatus implements Status { "权限被拒绝，应用Id和团队Id不能为空"), FLINK_SQL_IS_NULL_UPDATE_FAILED(10690, "Flink sql is null, update flink sql job failed.", "FlinkSql为空，更新FlinkSQL作业失败"), - FLINK_SQL_BACKUP_IS_NULL_ROLLBACK_FAILED(10700, "Application backup can't be null. Rollback flink sql failed.", + FLINK_SQL_BACKUP_IS_NULL_ROLLBACK_FAILED(10700, "Application backup can''t be null. Rollback flink sql failed.", "应用程序备份不能为为空，回滚FlinkSql失败"), ; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ProjectMessageStatus.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ProjectMessageStatus.java index 9c5c8913ac..38a22aab84 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ProjectMessageStatus.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ProjectMessageStatus.java @@ -24,11 +24,11 @@ @Getter public enum ProjectMessageStatus implements Status { - PROJECT_MODULE_NULL_ERROR(101070, "Project module can't be null, please check.", "项目模块不能为空，请检查"), + PROJECT_MODULE_NULL_ERROR(101070, "Project module can''t be null, please check.", "项目模块不能为空，请检查"), PROJECT_NAME_EXIST(101080, "project name already exists", "项目名称已存在"), PROJECT_GIT_PASSWORD_DECRYPT_FAILED(101090, "Project Github/Gitlab password decrypt failed", "项目 Github/Gitlab 密码解密失败"), - PROJECT_TEAM_ID_MODIFY_ERROR(101100, "TeamId can't be changed", "无法更改TeamId"), + PROJECT_TEAM_ID_MODIFY_ERROR(101100, "TeamId can''t be changed", "无法更改TeamId"), PROJECT_BUILDING_STATE(101110, "The project is being built", "该项目正在建设中"), PROJECT_RUNNING_BUILDING_EXCEED_LIMIT(101120, "The number of running Build projects exceeds the maximum number: {0}", diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ResourceMessageStatus.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ResourceMessageStatus.java index bf999dd6de..7c1345862e 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ResourceMessageStatus.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/ResourceMessageStatus.java @@ -26,7 +26,7 @@ public enum ResourceMessageStatus implements Status { RESOURCE_ALREADY_ERROR(10300, "the resource {0} already exists, please check.", "资源{0}已经存在，请检查"), RESOURCE_NAME_NULL_FAILED(10310, "The resource name cannot be null", "资源名不能为空"), - RESOURCE_NOT_EXIST_ERROR(10320, "the resource {0} doesn't exists, please check.", "资源{0}不存在，请检查"), + RESOURCE_NOT_EXIST_ERROR(10320, "the resource {0} doesn''t exists, please check.", "资源{0}不存在，请检查"), RESOURCE_STILL_USE_DELETE_ERROR(10330, "The resource is still in use, cannot be removed.", "资源仍在使用中，无法删除。"), RESOURCE_POM_JAR_EMPTY(10340, "Please add pom or jar resource.", "请添加pom或jar资源。"), RESOURCE_FLINK_APP_JAR_EMPTY_ERROR(10350, "Please upload jar for Flink App resource", "请上传 jar 以获取Flink App资源"), diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/UserMessageStatus.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/UserMessageStatus.java index 5b318cd064..ad3a1a704e 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/UserMessageStatus.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/UserMessageStatus.java @@ -52,14 +52,14 @@ public enum UserMessageStatus implements Status { "权限被拒绝，此作业不是由当前用户创建的，并且在当前用户的团队中找不到该作业"), SYSTEM_TEAM_ALREADY_EXIST(10190, "The team {0} already exist.", "团队{0}已经存在。"), - SYSTEM_TEAM_NOT_EXIST(10200, "The team {0} doesn't exist.", "团队{0} 不存在。"), + SYSTEM_TEAM_NOT_EXIST(10200, "The team {0} doesn''t exist.", "团队{0} 不存在。"), SYSTEM_TEAM_ID_CANNOT_NULL(10210, "The team id is cannot null.", "团队ID不能为空"), - SYSTEM_TEAM_ID_NOT_EXIST(10220, "The team id {0} doesn't exist.", "团队ID {0}不存在"), - SYSTEM_TEAM_NAME_CAN_NOT_CHANGE(10230, "Team name can't be changed. Update team failed.", "团队名称不能更改"), + SYSTEM_TEAM_ID_NOT_EXIST(10220, "The team id {0} doesn''t exist.", "团队ID {0}不存在"), + SYSTEM_TEAM_NAME_CAN_NOT_CHANGE(10230, "Team name can''t be changed. Update team failed.", "团队名称不能更改"), SYSTEM_LDAP_NOT_ENABLE(10240, "ldap is not enabled, Please check the configuration: ldap.enable", "LDAP未启用，请检查配置：ldap.enable"), - SYSTEM_TEAM_ID_NULL_ERROR(10250, "Team id mustn't be null.", "团队ID不能为空"), + SYSTEM_TEAM_ID_NULL_ERROR(10250, "Team id mustn''t be null.", "团队ID不能为空"), SYSTEM_TEAM_EXIST_MODULE_USE_DELETE_ERROR(10260, "Please delete the {1} under the team[{0}] first!", "请先删除团队[{0}]下的{1}！"), @@ -72,9 +72,9 @@ public enum UserMessageStatus implements Status { "There are some users of role {0}, delete role failed, please unbind it first.", "有一些用户的角色{0}，删除角色失败，请先解绑"), - MEMBER_USER_TEAM_ALREADY_ERROR(10390, "The user [{0}] has been added the team [{1}], please don't add it again.", + MEMBER_USER_TEAM_ALREADY_ERROR(10390, "The user [{0}] has been added the team [{1}], please don''t add it again.", "用户 [{0}] 已添加到团队 [{1}]，请不要再次添加"), - MEMBER_ID_NOT_EXIST(10400, "The member id {0} doesn't exist.", + MEMBER_ID_NOT_EXIST(10400, "The member id {0} doesn''t exist.", "成员ID {0}不存在"), MEMBER_TEAM_ID_CHANGE_ERROR(10410, "Team id cannot be changed.", "团队ID无法更改。"), diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/YarnMessageStatus.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/YarnMessageStatus.java index 6353287303..98a284f5a6 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/YarnMessageStatus.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/enums/YarnMessageStatus.java @@ -24,18 +24,18 @@ @Getter public enum YarnMessageStatus implements Status { - YARN_QUEUE_NOT_EXIST(10740, "The yarn queue doesn't exist.", "Yarn队列不存在"), - YARN_QUEUE_NULL(10750, "Yarn queue mustn't be empty.", "Yarn队列不能为空"), - YARN_QUEUE_ID_NULL(10760, "Yarn queue id mustn't be empty.", "Yarn队列ID不能为空"), + YARN_QUEUE_NOT_EXIST(10740, "The yarn queue doesn''t exist.", "Yarn队列不存在"), + YARN_QUEUE_NULL(10750, "Yarn queue mustn''t be empty.", "Yarn队列不能为空"), + YARN_QUEUE_ID_NULL(10760, "Yarn queue id mustn''t be empty.", "Yarn队列ID不能为空"), YARN_QUEUE_LABEL_EXIST(10770, "The queue label existed already. Try on a new queue label, please.", "队列标签已存在，请尝试使用新的队列标签。"), - YARN_QUEUE_LABEL_NULL(10780, "Yarn queue label mustn't be empty.", "Yarn队列标签不能为空"), + YARN_QUEUE_LABEL_NULL(10780, "Yarn queue label mustn''t be empty.", "Yarn队列标签不能为空"), YARN_QUEUE_LABEL_AVAILABLE(10790, "The queue label is availableThe queue label is available.", "队列标签可用队列标签可用"), YARN_QUEUE_LABEL_FORMAT(10800, "Yarn queue label format should be in format '{'queue'}' or '{'queue'}'@'{'label1，label2'}'", "Yarn队列标签格式应为格式 '{'queue'}' 或 '{'queue'}'@'{'label1，label2'}'"), - YARN_QUEUE_QUERY_PARAMS_NULL(10810, "Yarn queue query params mustn't be null.", "Yarn队列查询参数不能为空"), - YARN_QUEUE_QUERY_PARAMS_TEAM_ID_NULL(10820, "Team id of yarn queue query params mustn't be null.", + YARN_QUEUE_QUERY_PARAMS_NULL(10810, "Yarn queue query params mustn''t be null.", "Yarn队列查询参数不能为空"), + YARN_QUEUE_QUERY_PARAMS_TEAM_ID_NULL(10820, "Team id of yarn queue query params mustn''t be null.", "Yarn队列查询参数的团队ID不能为空"), YARN_QUEUE_USED_FORMAT(10830, "Please remove the yarn queue for {0} referenced it before {1}.", "请在{1}之前删除{0}引用的Yarn队列"),