You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/12/03 14:26:54 UTC
[incubator-streampark] 01/01: [Improve] i18n Improvement
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch i18n
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit 7507363f3507a163ba4aeaa140e5917a2285147b
Author: benjobs <be...@apache.org>
AuthorDate: Sat Dec 3 22:26:36 2022 +0800
[Improve] i18n Improvement
---
.../src/locales/lang/en/flink/app.ts | 5 ++++
.../src/locales/lang/en/flink/project.ts | 15 ++++++----
.../src/locales/lang/en/flink/setting.ts | 15 ++++++----
.../src/locales/lang/zh-CN/flink/app.ts | 7 ++++-
.../src/locales/lang/zh-CN/flink/project.ts | 10 +++----
.../src/locales/lang/zh-CN/flink/setting.ts | 31 +++++++++----------
.../src/locales/lang/zh-CN/menu.ts | 4 +--
.../src/views/flink/app/Detail.vue | 2 +-
.../flink/app/components/AppDetail/DetailTab.vue | 2 +-
.../src/views/flink/app/components/Dependency.vue | 1 -
.../flink/app/hooks/useCreateAndEditSchema.ts | 4 ++-
.../src/views/flink/app/hooks/useDetail.ts | 2 +-
.../src/views/flink/app/hooks/useFlinkRender.tsx | 7 ++---
.../views/flink/project/components/ListItem.vue | 14 +++++----
.../src/views/flink/project/project.data.ts | 20 ++++++++++---
.../src/views/flink/project/useProject.ts | 23 ++++++++++++--
.../src/views/flink/setting/AddCluster.vue | 10 +++++--
.../src/views/flink/setting/EditCluster.vue | 4 ++-
.../setting/components/FlinkClusterSetting.vue | 11 ++++---
.../flink/setting/components/FlinkEnvModal.vue | 35 ++++++++++++++++------
.../views/flink/setting/hooks/useClusterSetting.ts | 5 +++-
21 files changed, 154 insertions(+), 73 deletions(-)
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts b/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
index 9c2907ce9..acddee027 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
@@ -220,11 +220,14 @@ export default {
k8sRestExposedTypePlaceholder: 'kubernetes.rest-service.exposed.type',
hadoopXmlConfigFileTips:
'Automatically copy configuration files from system environment parameters',
+ dynamicPropertiesPlaceholder:
+ '$key=$value,If there are multiple parameters,you can new line enter them (-D <arg>)',
},
noteInfo: {
note: 'Note',
minute: 'minute',
count: 'count',
+ officialDoc: 'official document',
checkPointFailureOptions: 'CheckPoint Failure Options',
checkpointFailureRateInterval: 'checkpoint failure rate interval',
maxFailuresPerInterval: 'max failures per interval',
@@ -232,5 +235,7 @@ export default {
'Operation after checkpoint failure, e.g: Within 5 minutes (checkpoint failure rate interval), if the number of checkpoint failures reaches 10 (max failures per interval),action will be triggered(alert or restart job)',
totalMemoryNote:
'Explicitly configuring both "total process memory" and "total Flink memory" is not recommended. It may lead to deployment failures due to potential memory configuration conflicts. Configuring other memory components also requires caution as it can produce further configuration conflicts, The easiest way is to set "total process memory"',
+ dynamicProperties:
+ 'It works the same as -D$property=$value in CLI mode, Allows specifying multiple generic configuration options. The available options can be found from',
},
};
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/project.ts b/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/project.ts
index 70748d861..c09413070 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/project.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/project.ts
@@ -15,7 +15,7 @@
* limitations under the License.
*/
export default {
- projectStatus : {
+ projectStatus: {
all: 'ALL',
notBuild: 'Not Build',
building: 'Building',
@@ -26,7 +26,7 @@ export default {
failed: 'FAILED',
},
searchPlaceholder: 'please enter a keyword search',
- form : {
+ form: {
projectName: 'Project Name',
projectNamePlaceholder: 'please input Project Name',
projectType: 'Project Type',
@@ -42,7 +42,8 @@ export default {
branches: 'Branches',
branchesPlaceholder: 'Select a branch',
pom: 'POM',
- pomPlaceholder: 'By default,lookup pom.xml in root path,You can manually specify the module to compile pom.xmlh',
+ pomPlaceholder:
+ 'By default,lookup pom.xml in root path,You can manually specify the module to compile pom.xmlh',
buildArgs: 'Build Argument',
buildArgsPlaceholder: 'Build Argument, e.g: -Pprod',
description: 'description',
@@ -56,19 +57,21 @@ export default {
projectTypeIsRequiredMessage: 'Project Type is required',
cvsIsRequiredMessage: 'CVS is required',
repositoryURLIsRequiredMessage: 'Repository URL is required',
- pomSpecifiesModuleMessage: 'Specifies the module to compile pom.xml If it is not specified, it is found under the root path pom.xml',
+ pomSpecifiesModuleMessage:
+ 'Specifies the module to compile pom.xml If it is not specified, it is found under the root path pom.xml',
projectIsbuildingMessage: 'The current project is building',
projectIsbuildFailedMessage: 'Build Fail',
deleteProjectSuccessMessage: 'delete successful',
deleteProjectFailedMessage: 'Delete Fail',
deleteProjectFailedDetailMessage: 'Please check if any application belongs to this project',
notAuthorizedMessage: 'not authorized ..>﹏<.. <br><br> userName and password is required',
- authenticationErrorMessage: 'authentication error ..>﹏<.. <br><br> please check userName and password',
+ authenticationErrorMessage:
+ 'authentication error ..>﹏<.. <br><br> please check userName and password',
seeBuildLog: 'See Build log',
buildProject: 'Build Project',
buildProjectMessage: 'Are you sure build this project?',
updateProject: 'Update Project',
deleteProject: 'Delete Project',
deleteProjectMessage: 'Are you sure delete this project ?',
- }
+ },
};
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/setting.ts b/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/setting.ts
index bb99bfb54..41fbd6787 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/setting.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/en/flink/setting.ts
@@ -50,10 +50,10 @@ export default {
flinkNameIsUnique: 'flink name is already exists',
flinkNameIsRequired: 'flink name is required',
flinkHomeTips: 'The absolute path of the FLINK_HOME',
- flinkHomeIsRequired: 'flink name is required',
+ flinkHomeIsRequired: 'flink home is required',
createFlinkHomeSuccessful: ' create successful!',
updateFlinkHomeSuccessful: ' update successful!',
- }
+ },
},
alert: {
alertSetting: 'Alert Setting',
@@ -149,11 +149,13 @@ export default {
executionMode: 'Please enter cluster name',
versionId: 'please select Flink Version',
yarnQueue: 'Please enter yarn queue',
- addressRemoteMode: 'Please enter cluster address, multiple addresses use \',\' split e.g: http://host:port,http://host1:port2',
+ addressRemoteMode:
+ "Please enter cluster address, multiple addresses use ',' split e.g: http://host:port,http://host1:port2",
addressNoRemoteMode: 'Please enter cluster address, e.g: http://host:port',
yarnSessionClusterId: 'Please enter Yarn Session cluster',
k8sConf: '~/.kube/config',
- flinkImage: 'Please enter the tag of Flink base docker image, such as: flink:1.13.0-scala_2.11-java8',
+ flinkImage:
+ 'Please enter the tag of Flink base docker image, such as: flink:1.13.0-scala_2.11-java8',
k8sRestExposedType: 'kubernetes.rest-service.exposed.type',
resolveOrder: 'classloader.resolve-order',
taskSlots: 'Number of slots per TaskManager',
@@ -172,13 +174,14 @@ export default {
operateMessage: {
createFlinkSessionClusterSuccessful: ' create successful!',
createFlinkSessionClusterFailed: 'create cluster failed, please check log',
- hadoopEnvInitializationFailed: 'Hadoop environment initialization failed, please check the environment settings',
+ hadoopEnvInitializationFailed:
+ 'Hadoop environment initialization failed, please check the environment settings',
flinkClusterIsStarting: 'The current cluster is starting',
flinkClusterHasStartedSuccessful: 'The current cluster is started',
updateFlinkClusterSuccessful: ' update successful!',
},
view: {
- clusterId: 'ClusterId'
+ clusterId: 'ClusterId',
},
},
env: {
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
index ed01275be..e0eeda899 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
@@ -17,7 +17,7 @@
export default {
id: '作业ID',
appName: '作业名称',
- searchName: '名称',
+ searchName: '作业名称',
tags: '作业标签',
owner: '创建者',
flinkVersion: 'Flink版本',
@@ -213,11 +213,14 @@ export default {
flinkImageIsRequiredMessage: 'Flink基础docker镜像是必填的',
k8sRestExposedTypePlaceholder: 'K8S服务对外类型',
hadoopXmlConfigFileTips: '从系统环境参数自动复制配置文件',
+ dynamicPropertiesPlaceholder: '$key=$value,如果有多个参数，可以换行输入(-D <arg>)',
},
+
noteInfo: {
note: '提示',
minute: '分钟',
count: '次数',
+ officialDoc: '官网文档',
checkPointFailureOptions: 'CheckPoint失败策略',
checkpointFailureRateInterval: 'checkpoint失败间隔',
maxFailuresPerInterval: '最大失败次数',
@@ -225,5 +228,7 @@ export default {
'checkpoint 失败处理策略, 例如: 在 5 分钟内 (checkpoint的失败间隔), 如果 checkpoint 失败次数超过 10 次 (checkpoint最大失败次数),会触发操作(发送告警或者重启作业)',
totalMemoryNote:
'不建议同时配置 "total process memory" 和 "total Flink memory"。 由于潜在的内存配置冲突，它可能会导致部署失败。 配置其他内存组件也需要谨慎，因为它会产生进一步的配置冲突，最简单的方法是设置"total process memory"',
+ dynamicProperties:
+ '动态Properties: 与flink run命令行模式下的 -D$property=$value 的作用相同，允许指定多个参数。 更多可以设置的参数请查阅',
},
};
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/project.ts b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/project.ts
index 5d8d2cb90..6a335bfd3 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/project.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/project.ts
@@ -15,7 +15,7 @@
* limitations under the License.
*/
export default {
- projectStatus : {
+ projectStatus: {
all: '所有(状态)',
notBuild: '未构建',
building: '构建中',
@@ -26,13 +26,13 @@ export default {
failed: '失败',
},
searchPlaceholder: '请输入关键词搜索',
- form : {
+ form: {
projectName: '项目名称',
projectNamePlaceholder: '请输入项目名称',
projectType: '项目类型',
projectTypePlaceholder: '请选择项目类型',
- cvs: '项目来源',
- cvsPlaceholder: '项目来源',
+ cvs: 'CVS',
+ cvsPlaceholder: 'CVS类型: git/svn',
repositoryURL: '仓库地址',
repositoryURLPlaceholder: '请输入该项目的仓库地址',
userName: '项目用户名',
@@ -70,5 +70,5 @@ export default {
updateProject: '更新项目',
deleteProject: '删除项目',
deleteProjectMessage: '确定删除项目?',
- }
+ },
};
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/setting.ts b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/setting.ts
index bf0dc5fbd..ecb3ccc9e 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/setting.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/setting.ts
@@ -18,12 +18,12 @@ export default {
settingTab: {
systemSetting: '系统设置',
alertSetting: '告警设置',
- flinkHome: 'Flink配置',
- flinkCluster: 'Flink集群配置',
+ flinkHome: 'Flink版本',
+ flinkCluster: 'Flink集群',
},
systemSettingItems: {
mavenSetting: {
- name: 'Maven配置'
+ name: 'Maven配置',
},
dockerSetting: {
name: 'Docker环境配置',
@@ -39,21 +39,21 @@ export default {
},
},
flink: {
- flinkName: 'Flink环境(别名)',
- flinkNamePlaceholder: '请输入flink环境别名',
- flinkHome: 'Flink安装路径',
+ flinkName: 'Flink名称',
+ flinkNamePlaceholder: '请输入Flink别名',
+ flinkHome: '安装路径',
flinkHomePlaceholder: '请输入Flink安装路径',
- description: 'flink环境描述',
- descriptionPlaceholder: 'flink环境描述',
+ description: '描述',
+ descriptionPlaceholder: 'Flink描述',
operateMessage: {
- flinkNameTips: 'flink环境别名,举例: flink-1.12',
- flinkNameIsUnique: 'flink环境别名已存在',
- flinkNameIsRequired: 'flink环境别名必填',
- flinkHomeTips: 'flink所在服务器的绝对路径,举例: /usr/local/flink',
+ flinkNameTips: 'Flink别名,举例: Flink-1.12',
+ flinkNameIsUnique: 'Flink名称已存在',
+ flinkNameIsRequired: 'Flink名称必填',
+ flinkHomeTips: 'Flink所在服务器的绝对路径,举例: /usr/local/flink',
flinkHomeIsRequired: 'Flink安装路径必填',
createFlinkHomeSuccessful: ' 创建成功!',
updateFlinkHomeSuccessful: ' 更新成功!',
- }
+ },
},
alert: {
alertSetting: '告警设置',
@@ -147,7 +147,8 @@ export default {
executionMode: '请选择执行模式',
versionId: '请选择Flink版本',
yarnQueue: '请选择Yarn队列',
- addressRemoteMode: '请输入集群地址，多个地址使用英文逗号分割，例如：http://host:port,http://host1:port2',
+ addressRemoteMode:
+ '请输入集群地址，多个地址使用英文逗号分割，例如：http://host:port,http://host1:port2',
addressNoRemoteMode: '请输入集群地址，例如：http://host:port',
yarnSessionClusterId: '请输入Yarn Session模式集群ID',
k8sConf: '示例：~/.kube/config',
@@ -177,7 +178,7 @@ export default {
updateFlinkClusterSuccessful: ' 更新成功!',
},
view: {
- clusterId: '集群ID'
+ clusterId: '集群ID',
},
},
env: {
diff --git a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/menu.ts b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/menu.ts
index 5dd1e6ae1..e8c221c0e 100644
--- a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/menu.ts
+++ b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/menu.ts
@@ -23,8 +23,8 @@ export default {
tokenManagement: 'Token管理',
teamManagement: '团队管理',
memberManagement: '成员管理',
- project: '项目',
- application: '作业',
+ project: '项目管理',
+ application: '作业管理',
setting: '设置中心',
variable: '变量管理',
},
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue b/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
index 7ff3e6e87..5cccd05aa 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
@@ -50,7 +50,7 @@
const { Swal, createMessage } = useMessage();
const { copy } = useClipboard({
- legacy:true
+ legacy: true,
});
const { t } = useI18n();
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue b/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
index 04e6c5fe8..87476b3cf 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
@@ -56,7 +56,7 @@
const { createMessage } = useMessage();
const { t } = useI18n();
const { copy } = useClipboard({
- legacy:true
+ legacy: true,
});
const route = useRoute();
const props = defineProps({
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue b/streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue
index 0c741c0a4..a1c7bb4b5 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue
@@ -18,7 +18,6 @@
import { computed, defineComponent, onMounted, reactive, ref } from 'vue';
import { useI18n } from '/@/hooks/web/useI18n';
import { toPomString } from '../utils/Pom';
- import { isK8sExecMode } from '../utils';
export default defineComponent({
name: 'Dependency',
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts b/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts
index cc7b79e28..7bf0f08cd 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts
+++ b/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts
@@ -253,7 +253,9 @@ export const useCreateAndEditSchema = (
};
},
ifShow: ({ values }) => values.executionMode == ExecModeEnum.KUBERNETES_APPLICATION,
- rules: [{ required: true, message: t('flink.app.addAppTips.kubernetesClusterIdPlaceholder') }],
+ rules: [
+ { required: true, message: t('flink.app.addAppTips.kubernetesClusterIdPlaceholder') },
+ ],
},
{
field: 'clusterId',
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useDetail.ts b/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useDetail.ts
index 660daf333..9e6959d5c 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useDetail.ts
+++ b/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useDetail.ts
@@ -30,7 +30,7 @@ export const userDetail = (
const { createMessage } = useMessage();
const { copy } = useClipboard({
- legacy:true
+ legacy: true,
});
function getConfAction(record: Recordable): ActionItem[] {
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx b/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx
index 990cd20f8..ada4d0c1a 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx
+++ b/streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx
@@ -245,16 +245,15 @@ export const renderDynamicProperties = ({ model, field }: RenderCallbackParams)
<p class="conf-desc mt-10px">
<span class="note-info">
<Tag color="#2db7f5" class="tag-note">
- Note
+ {t('flink.app.noteInfo.note')}
</Tag>
- It works the same as <span class="note-elem">-D$property=$value</span> in CLI mode, Allows
- specifying multiple generic configuration options. The available options can be found
+ {t('flink.app.noteInfo.dynamicProperties')}
<a
href="https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html"
target="_blank"
class="pl-5px"
>
- here
+ Flink {t('flink.app.noteInfo.officialDoc')}
</a>
</span>
</p>
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/project/components/ListItem.vue b/streampark-console/streampark-console-webapp/src/views/flink/project/components/ListItem.vue
index f9eea8143..edcdbab90 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/project/components/ListItem.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/project/components/ListItem.vue
@@ -44,21 +44,21 @@
<ul class="list-content">
<li class="list-content_item">
- <span>{{t('flink.project.form.cvs')}}</span>
+ <span>{{ t('flink.project.form.cvs') }}</span>
<p><github-outlined /></p>
</li>
<li class="list-content_item">
- <span>{{t('flink.project.form.branches')}}</span>
+ <span>{{ t('flink.project.form.branches') }}</span>
<p>
<a-tag color="blue">{{ item.branches }}</a-tag>
</p>
</li>
<li class="list-content_item build_time">
- <span>{{t('flink.project.form.lastBuild')}}</span>
+ <span>{{ t('flink.project.form.lastBuild') }}</span>
<p>{{ item.lastBuild || '--' }}</p>
</li>
<li class="list-content_item build_state">
- <span>{{t('flink.project.form.buildState')}}</span>
+ <span>{{ t('flink.project.form.buildState') }}</span>
<p>
<a-tag :color="buildState.color" :class="tagClass">{{ buildState.label }}</a-tag>
</p>
@@ -186,7 +186,11 @@
});
emit('success', true);
} else {
- Swal.fire('Failed', t('flink.project.operationTips.deleteProjectFailedDetailMessage'), 'error');
+ Swal.fire(
+ 'Failed',
+ t('flink.project.operationTips.deleteProjectFailedDetailMessage'),
+ 'error',
+ );
}
} catch (e) {
createMessage.error(t('flink.project.operationTips.deleteProjectFailedMessage'));
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/project/project.data.ts b/streampark-console/streampark-console-webapp/src/views/flink/project/project.data.ts
index 9b6274e91..625b9ae36 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/project/project.data.ts
+++ b/streampark-console/streampark-console-webapp/src/views/flink/project/project.data.ts
@@ -33,15 +33,27 @@ export const statusList: Status[] = [
];
export const buildStateMap = {
- [String(BuildStateEnum.NOT_BUDIL)]: { color: '#C0C0C0', label: t('flink.project.projectStatus.notBuild') },
- [String(BuildStateEnum.NEED_REBUILD)]: { color: '#FFA500', label: t('flink.project.projectStatus.needRebuild') },
+ [String(BuildStateEnum.NOT_BUDIL)]: {
+ color: '#C0C0C0',
+ label: t('flink.project.projectStatus.notBuild'),
+ },
+ [String(BuildStateEnum.NEED_REBUILD)]: {
+ color: '#FFA500',
+ label: t('flink.project.projectStatus.needRebuild'),
+ },
[String(BuildStateEnum.BUILDING)]: {
color: '#1AB58E',
label: t('flink.project.projectStatus.building'),
className: 'status-processing-building',
},
- [String(BuildStateEnum.SUCCESSFUL)]: { color: '#52c41a', label: t('flink.project.projectStatus.successful') },
- [String(BuildStateEnum.FAILED)]: { color: '#f5222d', label: t('flink.project.projectStatus.failed') },
+ [String(BuildStateEnum.SUCCESSFUL)]: {
+ color: '#52c41a',
+ label: t('flink.project.projectStatus.successful'),
+ },
+ [String(BuildStateEnum.FAILED)]: {
+ color: '#f5222d',
+ label: t('flink.project.projectStatus.failed'),
+ },
};
export enum ProjectType {
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/project/useProject.ts b/streampark-console/streampark-console-webapp/src/views/flink/project/useProject.ts
index 3057c4c98..37617331c 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/project/useProject.ts
+++ b/streampark-console/streampark-console-webapp/src/views/flink/project/useProject.ts
@@ -61,7 +61,13 @@ export const useProject = () => {
optionFilterProp: 'children',
filterOption,
},
- rules: [{ required: true, type: 'number', message: t('flink.project.operationTips.projectTypeIsRequiredMessage') }],
+ rules: [
+ {
+ required: true,
+ type: 'number',
+ message: t('flink.project.operationTips.projectTypeIsRequiredMessage'),
+ },
+ ],
},
{
field: 'repository',
@@ -77,7 +83,13 @@ export const useProject = () => {
],
placeholder: t('flink.project.form.cvsPlaceholder'),
},
- rules: [{ required: true, type: 'number', message: t('flink.project.operationTips.cvsIsRequiredMessage') }],
+ rules: [
+ {
+ required: true,
+ type: 'number',
+ message: t('flink.project.operationTips.cvsIsRequiredMessage'),
+ },
+ ],
},
{
field: 'url',
@@ -86,7 +98,12 @@ export const useProject = () => {
componentProps: {
placeholder: t('flink.project.form.repositoryURLPlaceholder'),
},
- rules: [{ required: true, message: t('flink.project.operationTips.repositoryURLIsRequiredMessage') }],
+ rules: [
+ {
+ required: true,
+ message: t('flink.project.operationTips.repositoryURLIsRequiredMessage'),
+ },
+ ],
},
{
field: 'userName',
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/setting/AddCluster.vue b/streampark-console/streampark-console-webapp/src/views/flink/setting/AddCluster.vue
index 6046b03a9..1cc6191de 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/setting/AddCluster.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/setting/AddCluster.vue
@@ -56,13 +56,19 @@
if (resp) {
Swal.fire({
icon: 'success',
- title: values.clusterName.concat(t('flink.setting.cluster.operateMessage.createFlinkSessionClusterSuccessful')),
+ title: values.clusterName.concat(
+ t('flink.setting.cluster.operateMessage.createFlinkSessionClusterSuccessful'),
+ ),
showConfirmButton: false,
timer: 2000,
});
go('/flink/setting?activeKey=cluster');
} else {
- Swal.fire('Failed', t('flink.setting.cluster.operateMessage.createFlinkSessionClusterFailed'), 'error');
+ Swal.fire(
+ 'Failed',
+ t('flink.setting.cluster.operateMessage.createFlinkSessionClusterFailed'),
+ 'error',
+ );
}
} else {
Swal.fire('Failed', res.msg, 'error');
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/setting/EditCluster.vue b/streampark-console/streampark-console-webapp/src/views/flink/setting/EditCluster.vue
index 27467917c..e78e91b80 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/setting/EditCluster.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/setting/EditCluster.vue
@@ -70,7 +70,9 @@
fetchUpdateCluster(params);
Swal.fire({
icon: 'success',
- title: values.clusterName.concat(t('flink.setting.cluster.operateMessage.updateFlinkClusterSuccessful')),
+ title: values.clusterName.concat(
+ t('flink.setting.cluster.operateMessage.updateFlinkClusterSuccessful'),
+ ),
showConfirmButton: false,
timer: 2000,
});
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkClusterSetting.vue b/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkClusterSetting.vue
index 12ceaa86a..e5c4b1f10 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkClusterSetting.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkClusterSetting.vue
@@ -64,7 +64,10 @@
}
/* deploy */
async function handleDeployCluster(item: FlinkCluster) {
- const hide = createMessage.loading(t('flink.setting.cluster.operateMessage.flinkClusterIsStarting'), 0);
+ const hide = createMessage.loading(
+ t('flink.setting.cluster.operateMessage.flinkClusterIsStarting'),
+ 0,
+ );
try {
await fetchClusterStart(item.id);
await Swal.fire({
@@ -127,7 +130,7 @@
</ListItemMeta>
<div class="list-content" style="width: 15%">
<div class="list-content-item" style="width: 60%">
- <span>{{t('flink.setting.cluster.form.executionMode')}}</span>
+ <span>{{ t('flink.setting.cluster.form.executionMode') }}</span>
<p style="margin-top: 10px">
{{ item.executionModeEnum.toLowerCase() }}
</p>
@@ -135,7 +138,7 @@
</div>
<div class="list-content" style="width: 15%">
<div class="list-content-item" style="width: 80%">
- <span>{{t('flink.setting.cluster.view.clusterId')}}</span>
+ <span>{{ t('flink.setting.cluster.view.clusterId') }}</span>
<p style="margin-top: 10px">
{{ item.clusterId }}
</p>
@@ -143,7 +146,7 @@
</div>
<div class="list-content" style="width: 20%">
<div class="list-content-item" style="width: 60%">
- <span>{{t('flink.setting.cluster.form.address')}}</span>
+ <span>{{ t('flink.setting.cluster.form.address') }}</span>
<p style="margin-top: 10px">
{{ item.address }}
</p>
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkEnvModal.vue b/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkEnvModal.vue
index 15812986a..b4fcb0a5f 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkEnvModal.vue
+++ b/streampark-console/streampark-console-webapp/src/views/flink/setting/components/FlinkEnvModal.vue
@@ -54,8 +54,15 @@
placeholder: t('flink.setting.flink.flinkNamePlaceholder'),
allowClear: true,
},
- afterItem: () => h('span', { class: 'conf-switch' }, t('flink.setting.flink.operateMessage.flinkNameTips')),
- rules: [{ required: true, message: t('flink.setting.flink.operateMessage.flinkNameIsRequired') }],
+ afterItem: () =>
+ h(
+ 'span',
+ { class: 'conf-switch' },
+ t('flink.setting.flink.operateMessage.flinkNameTips'),
+ ),
+ rules: [
+ { required: true, message: t('flink.setting.flink.operateMessage.flinkNameIsRequired') },
+ ],
},
{
field: 'flinkHome',
@@ -65,12 +72,19 @@
placeholder: t('flink.setting.flink.flinkHomePlaceholder'),
allowClear: true,
},
- afterItem: () => h('span', { class: 'conf-switch' }, t('flink.setting.flink.operateMessage.flinkHomeTips')),
- rules: [{ required: true, message: t('flink.setting.flink.operateMessage.descriptionPlaceholder') }],
+ afterItem: () =>
+ h(
+ 'span',
+ { class: 'conf-switch' },
+ t('flink.setting.flink.operateMessage.flinkHomeTips'),
+ ),
+ rules: [
+ { required: true, message: t('flink.setting.flink.operateMessage.flinkHomeIsRequired') },
+ ],
},
{
field: 'description',
- label: t('flink.setting.flink.description'),
+ label: t('flink.setting.flink.description'),
component: 'InputTextArea',
componentProps: {
placeholder: t('flink.setting.flink.descriptionPlaceholder'),
@@ -100,14 +114,16 @@
});
// Environment detection is successful
if (resp.data) {
- let message = '';
+ let message: string;
let success = false;
// create
if (versionId.value == null) {
const { data } = await fetchFlinkCreate(formValue);
if (data.data) {
success = true;
- message = formValue.flinkName.concat(t('flink.setting.flink.operateMessage.createFlinkHomeSuccessful'));
+ message = formValue.flinkName.concat(
+ t('flink.setting.flink.operateMessage.createFlinkHomeSuccessful'),
+ );
} else {
message = data.message;
}
@@ -118,7 +134,9 @@
...formValue,
});
if (data.data) {
- message = formValue.flinkName.concat(t('flink.setting.flink.operateMessage.updateFlinkHomeSuccessful'));
+ message = formValue.flinkName.concat(
+ t('flink.setting.flink.operateMessage.updateFlinkHomeSuccessful'),
+ );
success = true;
} else {
message = data.message;
@@ -160,7 +178,6 @@
),
});
} else {
- console.error(error);
createMessage.error('error');
}
} finally {
diff --git a/streampark-console/streampark-console-webapp/src/views/flink/setting/hooks/useClusterSetting.ts b/streampark-console/streampark-console-webapp/src/views/flink/setting/hooks/useClusterSetting.ts
index 95d80394f..5e742e045 100644
--- a/streampark-console/streampark-console-webapp/src/views/flink/setting/hooks/useClusterSetting.ts
+++ b/streampark-console/streampark-console-webapp/src/views/flink/setting/hooks/useClusterSetting.ts
@@ -273,7 +273,10 @@ export const useClusterSetting = () => {
label: t('flink.setting.cluster.form.resolveOrder'),
ifShow: ({ values }) => isShowInSessionMode(values),
component: 'Select',
- componentProps: { placeholder: t('flink.setting.cluster.placeholder.resolveOrder'), options: resolveOrder },
+ componentProps: {
+ placeholder: t('flink.setting.cluster.placeholder.resolveOrder'),
+ options: resolveOrder,
+ },
rules: [{ message: t('flink.setting.cluster.placeholder.resolveOrder'), type: 'number' }],
},
{