Browse Source

fix

pull/3/MERGE
break60 4 years ago
parent
commit
2c460c6278
  1. 1
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.vue
  2. 6
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/flink.vue
  3. 6
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/mr.vue
  4. 6
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/python.vue
  5. 6
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/shell.vue
  6. 6
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/spark.vue
  7. 20
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/plugIn/jsPlumbHandle.js
  8. 3
      dolphinscheduler-ui/src/js/conf/home/pages/dag/index.vue
  9. 6
      dolphinscheduler-ui/src/js/module/i18n/locale/en_US.js
  10. 6
      dolphinscheduler-ui/src/js/module/i18n/locale/zh_CN.js

1
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.vue

@ -434,7 +434,6 @@
this.$message.warning(`${i18n.$t('Failed to create node to save')}`) this.$message.warning(`${i18n.$t('Failed to create node to save')}`)
return return
} }
// Global parameters (optional) // Global parameters (optional)
this._udpTopFloorPop().then(() => { this._udpTopFloorPop().then(() => {
return this._save() return this._save()

6
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/flink.vue

@ -317,7 +317,7 @@
// noRes // noRes
if (this.noRes.length>0) { if (this.noRes.length>0) {
this.$message.warning(`${i18n.$t('Please delete all non-existent resources')}`) this.$message.warning(`${i18n.$t('Please delete all non-existing resources')}`)
return false return false
} }
@ -402,8 +402,8 @@
} }
let noResources = [{ let noResources = [{
id: -1, id: -1,
name: $t('Unauthorized or deleted resources'), name: $t('No resources exist'),
fullName: '/'+$t('Unauthorized or deleted resources'), fullName: '/'+$t('No resources exist'),
children: [] children: []
}] }]
if(optionsCmp.length>0) { if(optionsCmp.length>0) {

6
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/mr.vue

@ -242,8 +242,8 @@
} }
let noResources = [{ let noResources = [{
id: -1, id: -1,
name: $t('Unauthorized or deleted resources'), name: $t('No resources exist'),
fullName: '/'+$t('Unauthorized or deleted resources'), fullName: '/'+$t('No resources exist'),
children: [] children: []
}] }]
if(optionsCmp.length>0) { if(optionsCmp.length>0) {
@ -276,7 +276,7 @@
// noRes // noRes
if (this.noRes.length>0) { if (this.noRes.length>0) {
this.$message.warning(`${i18n.$t('Please delete all non-existent resources')}`) this.$message.warning(`${i18n.$t('Please delete all non-existing resources')}`)
return false return false
} }

6
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/python.vue

@ -129,7 +129,7 @@
// noRes // noRes
if (this.noRes.length>0) { if (this.noRes.length>0) {
this.$message.warning(`${i18n.$t('Please delete all non-existent resources')}`) this.$message.warning(`${i18n.$t('Please delete all non-existing resources')}`)
return false return false
} }
@ -222,8 +222,8 @@
} }
let noResources = [{ let noResources = [{
id: -1, id: -1,
name: $t('Unauthorized or deleted resources'), name: $t('No resources exist'),
fullName: '/'+$t('Unauthorized or deleted resources'), fullName: '/'+$t('No resources exist'),
children: [] children: []
}] }]
if(optionsCmp.length>0) { if(optionsCmp.length>0) {

6
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/shell.vue

@ -165,7 +165,7 @@
} }
// noRes // noRes
if (this.noRes.length>0) { if (this.noRes.length>0) {
this.$message.warning(`${i18n.$t('Please delete all non-existent resources')}`) this.$message.warning(`${i18n.$t('Please delete all non-existing resources')}`)
return false return false
} }
// Process resourcelist // Process resourcelist
@ -260,8 +260,8 @@
} }
let noResources = [{ let noResources = [{
id: -1, id: -1,
name: $t('Unauthorized or deleted resources'), name: $t('No resources exist'),
fullName: '/'+$t('Unauthorized or deleted resources'), fullName: '/'+$t('No resources exist'),
children: [] children: []
}] }]
if(optionsCmp.length>0) { if(optionsCmp.length>0) {

6
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/spark.vue

@ -362,8 +362,8 @@
} }
let noResources = [{ let noResources = [{
id: -1, id: -1,
name: $t('Unauthorized or deleted resources'), name: $t('No resources exist'),
fullName: '/'+$t('Unauthorized or deleted resources'), fullName: '/'+$t('No resources exist'),
children: [] children: []
}] }]
if(optionsCmp.length>0) { if(optionsCmp.length>0) {
@ -401,7 +401,7 @@
// noRes // noRes
if (this.noRes.length>0) { if (this.noRes.length>0) {
this.$message.warning(`${i18n.$t('Please delete all non-existent resources')}`) this.$message.warning(`${i18n.$t('Please delete all non-existing resources')}`)
return false return false
} }

20
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/plugIn/jsPlumbHandle.js

@ -666,7 +666,18 @@ JSP.prototype.saveStore = function () {
y: v.y y: v.y
} }
}) })
let targetArrBool = false
_.forEach(locations, item => {
if(item.targetarr) {
targetArrBool = true
return false
}
})
if(connects.length && !targetArrBool) {
Vue.$message.warning(`${i18n.$t('The workflow canvas is abnormal and cannot be saved, please recreate')}`)
return false
}
// return false
// Storage node // Storage node
store.commit('dag/setTasks', tasks) store.commit('dag/setTasks', tasks)
// Store coordinate information // Store coordinate information
@ -697,13 +708,6 @@ JSP.prototype.handleEvent = function () {
console.log(sourceId,targetId) console.log(sourceId,targetId)
let rtTargetArrs = rtTargetArr(targetId) let rtTargetArrs = rtTargetArr(targetId)
let rtSouceArrs = rtTargetArr(sourceId) let rtSouceArrs = rtTargetArr(sourceId)
/**
* When connecting, connection is prohibited when the sourceId and target nodes are empty
*/
if(!sourceId && !targetId) {
Vue.$message.warning(`${i18n.$t('This canvas is abnormal and the node connection cannot be made. Please save or exit the current workflow')}`)
return false
}
/** /**
* Recursive search for nodes * Recursive search for nodes
*/ */

3
dolphinscheduler-ui/src/js/conf/home/pages/dag/index.vue

@ -57,10 +57,9 @@
this.getProjectList(), this.getProjectList(),
// get jar // get jar
this.getResourcesListJar(), this.getResourcesListJar(),
this.getResourcesListJar('PYTHON'),
// get resource // get resource
this.getResourcesList(), this.getResourcesList(),
// get jar
this.getResourcesListJar(),
// get worker group list // get worker group list
this.getWorkerGroupsAll(), this.getWorkerGroupsAll(),
this.getTenantList() this.getTenantList()

6
dolphinscheduler-ui/src/js/module/i18n/locale/en_US.js

@ -591,8 +591,8 @@ export default {
'Branch flow': 'Branch flow', 'Branch flow': 'Branch flow',
'Cannot select the same node for successful branch flow and failed branch flow': 'Cannot select the same node for successful branch flow and failed branch flow', 'Cannot select the same node for successful branch flow and failed branch flow': 'Cannot select the same node for successful branch flow and failed branch flow',
'Successful branch flow and failed branch flow are required': 'conditions node Successful and failed branch flow are required', 'Successful branch flow and failed branch flow are required': 'conditions node Successful and failed branch flow are required',
'Unauthorized or deleted resources': 'Unauthorized or deleted resources', 'No resources exist': 'No resources exist',
'Please delete all non-existent resources': 'Please delete all non-existent resources', 'Please delete all non-existing resources': 'Please delete all non-existing resources',
'The Worker group no longer exists, please select the correct Worker group!': 'The Worker group no longer exists, please select the correct Worker group!', 'The Worker group no longer exists, please select the correct Worker group!': 'The Worker group no longer exists, please select the correct Worker group!',
'Please confirm whether the workflow has been saved before downloading': 'Please confirm whether the workflow has been saved before downloading', 'Please confirm whether the workflow has been saved before downloading': 'Please confirm whether the workflow has been saved before downloading',
'User name length is between 3 and 39': 'User name length is between 3 and 39', 'User name length is between 3 and 39': 'User name length is between 3 and 39',
@ -601,5 +601,5 @@ export default {
'Connection name': 'Connection name', 'Connection name': 'Connection name',
'Current connection settings': 'Current connection settings', 'Current connection settings': 'Current connection settings',
'Please save the DAG before formatting': 'Please save the DAG before formatting', 'Please save the DAG before formatting': 'Please save the DAG before formatting',
'This canvas is abnormal and the node connection cannot be made. Please save or exit the current workflow': 'This canvas is abnormal and the node connection cannot be made. Please save or exit the current workflow' 'The workflow canvas is abnormal and cannot be saved, please recreate': 'The workflow canvas is abnormal and cannot be saved, please recreate'
} }

6
dolphinscheduler-ui/src/js/module/i18n/locale/zh_CN.js

@ -591,8 +591,8 @@ export default {
'Branch flow': '分支流转', 'Branch flow': '分支流转',
'Cannot select the same node for successful branch flow and failed branch flow': '成功分支流转和失败分支流转不能选择同一个节点', 'Cannot select the same node for successful branch flow and failed branch flow': '成功分支流转和失败分支流转不能选择同一个节点',
'Successful branch flow and failed branch flow are required': 'conditions节点成功和失败分支流转必填', 'Successful branch flow and failed branch flow are required': 'conditions节点成功和失败分支流转必填',
'Unauthorized or deleted resources': '未授权或已删除资源', 'No resources exist': '不存在资源',
'Please delete all non-existent resources': '请删除所有未授权或已删除资源', 'Please delete all non-existing resources': '请删除所有不存在资源',
'The Worker group no longer exists, please select the correct Worker group!': '该Worker分组已经不存在请选择正确的Worker分组', 'The Worker group no longer exists, please select the correct Worker group!': '该Worker分组已经不存在请选择正确的Worker分组',
'Please confirm whether the workflow has been saved before downloading': '下载前请确定工作流是否已保存', 'Please confirm whether the workflow has been saved before downloading': '下载前请确定工作流是否已保存',
'User name length is between 3 and 39': '用户名长度在339之间', 'User name length is between 3 and 39': '用户名长度在339之间',
@ -607,5 +607,5 @@ export default {
'Connection name': '连线名', 'Connection name': '连线名',
'Current connection settings': '当前连线设置', 'Current connection settings': '当前连线设置',
'Please save the DAG before formatting': '格式化前请先保存DAG', 'Please save the DAG before formatting': '格式化前请先保存DAG',
'This canvas is abnormal and the node connection cannot be made. Please save or exit the current workflow': '此画布异常无法进行节点连线请保存或退出当前工作流' 'The workflow canvas is abnormal and cannot be saved, please recreate': '该工作流画布异常无法保存请重新创建'
} }

Loading…
Cancel
Save