Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
65 commits
Select commit Hold shift + click to select a range
b419612
feat(instance): Change button color
StormKennen Oct 24, 2023
6a123cf
feat(TaskStatus): Add taskRetryStartTimeTip
StormKennen Oct 25, 2023
ee452c2
feat(TaskStatus): Add enableCustomCommand
StormKennen Oct 25, 2023
7d40d29
feat(Verify/ConditionBox): Add lazy params
StormKennen Oct 26, 2023
9cdf9d3
refactor: update setSelected logic
cn-xufei Oct 26, 2023
453d3b7
refactor: update materialized view schema tree logic display all inpu…
cn-xufei Oct 26, 2023
003f8e2
Merge pull request #168
cn-xufei Oct 26, 2023
911640b
fix: task monitor display empty
cn-xufei Oct 26, 2023
97e02e1
refactor: reload target node schema after delete node
cn-xufei Oct 26, 2023
8cdbc5f
feat(milestone/List): Add error icon
StormKennen Oct 26, 2023
d1fb08a
refactor: materialized view add only support mongodb
cn-xufei Oct 26, 2023
9eda06f
refactor: materialized view add start button
cn-xufei Oct 26, 2023
1b2b108
Merge pull request #169
cn-xufei Oct 26, 2023
664266f
refactor: update node disabled connection check
cn-xufei Oct 26, 2023
b36c102
Merge pull request #170
cn-xufei Oct 26, 2023
a5bb8ca
refactor: connection list search params save on the url, return to th…
cn-xufei Oct 26, 2023
8296310
Merge pull request #171
cn-xufei Oct 27, 2023
67432ce
refactor: return to dataVerificationList after saving with back()
cn-xufei Oct 27, 2023
94aaad9
Merge pull request #172
cn-xufei Oct 27, 2023
151f992
fix(@tap/dag): request node schema when the task saves unresponsive, …
cn-xufei Oct 27, 2023
53eea71
Merge pull request #173
cn-xufei Oct 27, 2023
62c2866
fix: instance size display task num error
cn-xufei Oct 27, 2023
9036762
refactor: create agent add loading skeleton
cn-xufei Oct 27, 2023
f5b5173
refactor: update task name maxlength to 200
cn-xufei Oct 27, 2023
c368f3f
refactor: monitor page update task name maxlength to 200
cn-xufei Oct 27, 2023
cfa405c
feat(node/Table.js): Add concurrentWritePartitionMap
StormKennen Oct 29, 2023
beb9bba
fix(table-field-select): Add value params
StormKennen Oct 29, 2023
3d8b316
fix(table-field-select): Add init function
StormKennen Oct 29, 2023
551f5f9
fix(dag/formScope): Add validateConcurrentWritePartitionMap
StormKennen Oct 29, 2023
d614e28
Merge pull request #175 from tapdata/hotfix-v3.5.5-concurrentWritePar…
StormKennen Oct 29, 2023
119eff0
feat(node/Table.js): Add concurrentWritePartitionMap
StormKennen Oct 29, 2023
88596a6
fix(table-field-select): Add value params
StormKennen Oct 29, 2023
f87ed97
fix(table-field-select): Add init function
StormKennen Oct 29, 2023
e5e7d07
fix(dag/formScope): Add validateConcurrentWritePartitionMap
StormKennen Oct 29, 2023
c98a6ad
feat(instance): Delete tapdataAgentStatus
StormKennen Oct 16, 2023
190dfb1
Merge remote-tracking branch 'origin/feature-task-retry-tip' into dev…
StormKennen Oct 30, 2023
f4e4e41
fix(dag/formScope): Add isEmpty is error in validateConcurrentWritePa…
StormKennen Oct 31, 2023
d6b8c8d
Merge pull request #177 from tapdata/hotfix-v3.5.5-concurrentWritePar…
StormKennen Oct 31, 2023
f22c16a
fix(task/List): Check agent amount is zero
StormKennen Oct 31, 2023
bd185d8
Merge pull request #178 from tapdata/hotfix-v3.5.5-freetier-agent
StormKennen Oct 31, 2023
4e51514
fix(table-field-select): Change init function
StormKennen Oct 31, 2023
bb264ea
fix(table-field-select): Check disabled when run handleChange
StormKennen Oct 31, 2023
46cc4f3
Merge pull request #181 from tapdata/hotfix-v3.5.5-tableFieldSelect
StormKennen Nov 1, 2023
256ad3b
Merge branch 'release-v3.5.5' into develop
StormKennen Nov 1, 2023
7774a44
fix(@tap/dag): after the connection configuration is updated, the nod…
cn-xufei Nov 2, 2023
bb4f0e0
Merge pull request #182 from tapdata/fix/task-agent-set
cn-xufei Nov 2, 2023
2bc376a
fix(@tap/dag): after the connection configuration is updated, the nod…
cn-xufei Nov 2, 2023
b57dc88
Merge pull request #183 from tapdata/fix/task-agent-set
cn-xufei Nov 2, 2023
9411149
refactor(@tap/dag): update node disable button position
cn-xufei Nov 2, 2023
69cd466
Merge pull request #184 from tapdata/fix/dag-node-action
cn-xufei Nov 2, 2023
f0ee0e3
Merge branch 'release-v3.5.5' into develop
cn-xufei Nov 2, 2023
1f3b283
fix(daas/user/list): The list has duplicate role names #148949
StormKennen Nov 2, 2023
8d010ea
Merge remote-tracking branch 'origin/develop' into develop
StormKennen Nov 2, 2023
371eb1f
feat(@tap/dag): merge_table_processor add center node action
cn-xufei Nov 2, 2023
72b8ffc
fix(dfs/instance): Change stop button in primaryColor
StormKennen Nov 3, 2023
145c5dd
Merge remote-tracking branch 'origin/develop' into develop
StormKennen Nov 3, 2023
590b85a
refactor(@tap/dag): update merge_table_processor style
cn-xufei Nov 3, 2023
1b9ffbb
Merge remote-tracking branch 'origin/develop' into develop
cn-xufei Nov 3, 2023
56ff481
refactor(@tap/dag): remove useless code
cn-xufei Nov 3, 2023
9c5f20f
feat(@tap/dag): node name add copy node id
cn-xufei Nov 3, 2023
7426877
refactor(@tap/dag): update alarmSettings/alarmRules event effect and …
cn-xufei Nov 6, 2023
3faa968
refactor: add guide buried guideCreateTask/guideCreateSourceConnectio…
cn-xufei Nov 6, 2023
85cd897
Merge branch 'develop' into feature-verify-sql
StormKennen Nov 7, 2023
e04bf94
refactor(dfs): config.json add 'Cache-Control': 'no-cache'
cn-xufei Nov 7, 2023
4a81f0d
chore: update pkg and vue.config.js
cn-xufei Nov 7, 2023
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions apps/daas/src/plugins/axios.ts
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ const errorCallback = (error: AxiosError): Promise<AxiosError | string> => {
if (axios.isCancel(error)) {
// eslint-disable-next-line no-console
console.log('Request canceled', error.message)
return Promise.reject('Request canceled')
return Promise.reject(error)
}
if (error?.config || error?.response?.config) {
removePending(error.config || error.response.config)
Expand Down Expand Up @@ -114,7 +114,7 @@ axios.interceptors.request.use(function (config: AxiosRequestConfig): AxiosReque
cancelFunc = c
})
if (pending.includes(key)) {
console.log('Cancel request:', JSON.parse(key)) //eslint-disable-line
console.warn('Cancel request:', JSON.parse(key)) //eslint-disable-line
cancelFunc()
} else if (config.method !== 'get') {
pending.push(key)
Expand Down
11 changes: 6 additions & 5 deletions apps/daas/src/views/user/List.vue
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@
</el-table-column>
<el-table-column :label="$t('user_list_role')" prop="roleMappings">
<template slot-scope="scope">
{{ permissionsmethod(scope.row.roleMappings) }}
{{ permissionsmethod(scope.row.roleMappings, scope.row.roleusers) }}
</template>
</el-table-column>
<el-table-column :label="$t('user_list_change_time')" prop="last_updated" sortable="last_updated">
Expand Down Expand Up @@ -769,12 +769,13 @@ export default {
})
},
// 关联用户
permissionsmethod(data) {
permissionsmethod(data = [], roleusers = []) {
let html = ''
if (data && data.length) {
data.forEach(item => {
if (item.role && item.role.name) {
html += ' ' + item.role.name + ','
roleusers.forEach(item => {
const roleName = data.find(t => t.roleId === item)?.role?.name
if (roleName) {
html += ' ' + roleName + ','
}
})
}
Expand Down
2 changes: 1 addition & 1 deletion apps/daas/vue.config.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ const proxy = {

module.exports = {
assetsDir: 'static',
lintOnSave: process.env.NODE_ENV !== 'production', // 打包时关闭lint输出
lintOnSave: SERVE_ENV !== 'dev' && process.env.NODE_ENV !== 'production', // 打包时关闭lint输出
productionSourceMap: false,
publicPath: './',
devServer: {
Expand Down
23 changes: 5 additions & 18 deletions apps/dfs/src/components/guide/Spec.vue
Original file line number Diff line number Diff line change
Expand Up @@ -221,20 +221,17 @@ export default {
this.specificationItems = uniqBy(
paidPrice.map(t => {
const { cpu = 0, memory = 0 } = t.spec || {}
let desc = i18n.t('dfs_agent_download_subscriptionmodeldialog_renwushujianyi', {
val: this.getSuggestPipelineNumber(cpu, memory)
})
if (t.chargeProvider === 'FreeTier') {
desc = i18n.t('dfs_agent_download_subscriptionmodeldialog_mianfeishilizui')
}

return {
label: getSpec(t.spec),
value: getSpec(t.spec),
cpu,
memory,
name: t.spec.name.toUpperCase(),
chargeProvider: t.chargeProvider,
desc: desc
desc: i18n.t('dfs_agent_download_subscriptionmodeldialog_renwushujianyi', {
val: t.limitTask
})
}
}),
'value'
Expand Down Expand Up @@ -267,16 +264,7 @@ export default {
console.log('specificationItems', this.specificationItems) // eslint-disable-line
})
},
//查询定价列表
getSuggestPipelineNumber(cpu, memory) {
if (memory == 2) {
return 3
}
if (memory == 4) {
return 5
}
return memory / 0.8
},

//订购时长对应价格
loadPackageItems() {
const specification = this.specificationItems.find(t => t.value === this.specification)
Expand Down Expand Up @@ -359,7 +347,6 @@ export default {
updateAgentCap(cpu, memory) {
return {
mem: parseInt(memory * 1.1 + 2) + 'G',
pipeline: this.getSuggestPipelineNumber(cpu, memory),
tps: cpu * 2000
}
},
Expand Down
2 changes: 2 additions & 0 deletions apps/dfs/src/i18n/langs/en.js
Original file line number Diff line number Diff line change
Expand Up @@ -1388,6 +1388,8 @@ export default {
'1. After 1 day expires, the Agent will be automatically stopped (the tasks running on the Agent will also be stopped)',
dfs_instance_expired_time_full_tip3:
'2. When the instance is stopped due to expiration, the instance can be resumed by renewal to continue running tasks',
dfs_instance_tapdata_agent_status_tip:
'The tapdata start/stop management service is offline. Please manually perform the start/stop operation in the installation directory.',
dfs_user_center_zhifufuwu: 'Payment Service',
dfs_user_center_ninjiangzhifur:
'You will pay for the "{val1}" service, and you will enjoy the service after payment. Are you sure whether to continue? ',
Expand Down
1 change: 1 addition & 0 deletions apps/dfs/src/i18n/langs/zh-CN.js
Original file line number Diff line number Diff line change
Expand Up @@ -1288,6 +1288,7 @@ export default {
dfs_instance_expired_time_tip4: '3.实例因过期禁止调度时,可以通过续费恢复实例继续调度运行任务',
dfs_instance_expired_time_full_tip2: '1.过期1天后,将自动停止 Agent(Agent 上运行的任务也会停止)',
dfs_instance_expired_time_full_tip3: '2.实例因过期停止时,可以通过续费恢复实例继续运行任务',
dfs_instance_tapdata_agent_status_tip: 'tapdata启停管理服务已离线,请手动在安装目录执行启停操作',
dfs_user_center_zhifufuwu: '支付服务',
dfs_user_center_ninjiangzhifur: '您将支付“{val1}”业务,支付后您将享受该服务,确定是否继续?',
dfs_user_center_xudingfuwu: '续订服务',
Expand Down
1 change: 1 addition & 0 deletions apps/dfs/src/i18n/langs/zh-TW.js
Original file line number Diff line number Diff line change
Expand Up @@ -1259,6 +1259,7 @@ export default {
dfs_instance_expired_time_tip4: '3.实例因过期禁止调度时,可以通过续费恢复实例继续调度运行任务',
dfs_instance_expired_time_full_tip2: '1.过期1天后,将自动停止 Agent(Agent 上运行的任务也会停止)',
dfs_instance_expired_time_full_tip3: '2.实例因过期停止时,可以通过续费恢复实例继续运行任务',
dfs_instance_tapdata_agent_status_tip: 'tapdata啟停管理服務已離線,請手動在安裝目錄執行啟停操作。',
dfs_user_center_zhifufuwu: '支付服務',
dfs_user_center_ninjiangzhifur: '您將支付“{val1}”業務,支付後您將享受該服務,確定是否繼續? ',
dfs_user_center_xudingfuwu: '續訂服務',
Expand Down
4 changes: 2 additions & 2 deletions apps/dfs/src/init.js
Original file line number Diff line number Diff line change
Expand Up @@ -210,10 +210,10 @@ export default ({ routes }) => {

window.axios
.get('config/config.json', {
cache: false,
responseType: 'json',
headers: {
Accept: 'application/json'
Accept: 'application/json',
'Cache-Control': 'no-cache'
}
})
.then(res => {
Expand Down
6 changes: 2 additions & 4 deletions apps/dfs/src/plugins/axios.js
Original file line number Diff line number Diff line change
Expand Up @@ -48,9 +48,7 @@ let skipErrorHandler = false
const errorCallback = error => {
let status = error?.response?.status
if (axios.isCancel(error)) {
// eslint-disable-next-line no-console
console.log('Request canceled', error.message)
return Promise.reject('Request canceled')
return Promise.reject(error)
}
// 从请求池清除掉错误请求
if (error?.response?.config || error?.config) {
Expand Down Expand Up @@ -122,7 +120,7 @@ const requestInterceptor = config => {
let key = getPendingKey(config)
// 判断请求池是否有相同请求,有则取消当前请求(后一条),没有则将请求注入请求池
if (pending.includes(key)) {
console.log('Cancel request:', config) //eslint-disable-line
console.warn('Cancel request:', config) //eslint-disable-line
cancelFunc('cancel')
} else if (config.method !== 'get') {
pending.push(key)
Expand Down
Loading