lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(web): 修复单表压缩任务提交

Browse Source
This commit is contained in:
兰缘小妖
2024-01-03 18:39:28 +08:00
parent 770336f0ae
commit df36657d0c
2 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/ScheduleController.java
View File

@@ -1,6 +1,7 @@
package com.lanyuanxiaoyao.service.web.controller;
import cn.hutool.core.util.ReUtil;
import cn.hutool.core.util.StrUtil;
import com.lanyuanxiaoyao.service.configuration.entity.info.JobIdAndAlias;
import com.lanyuanxiaoyao.service.configuration.exception.TableNotFoundException;
import com.lanyuanxiaoyao.service.forest.service.InfoService;
@@ -57,8 +58,14 @@ public class ScheduleController extends BaseController {
@RequestParam(value = "force", required = false) String forceCluster,
@RequestParam(value = "recommend", required = false) String recommendCluster
) throws TableNotFoundException {
// checkTableExists(infoService, flinkJobId, alias);
// scheduleService.scheduleTable(flinkJobId, alias);
checkTableExists(infoService, flinkJobId, alias);
if (StrUtil.isNotBlank(forceCluster)) {
scheduleService.scheduleTableForce(flinkJobId, alias, forceCluster);
} else if (StrUtil.isNotBlank(recommendCluster)) {
scheduleService.scheduleTableRecommend(flinkJobId, alias, recommendCluster);
} else {
scheduleService.scheduleTable(flinkJobId, alias);
}
return AmisResponse.responseSuccess();
}
}

2
service-web/src/main/resources/static/components/tool-tab.js
View File

@@ -170,6 +170,7 @@ function toolTab() {
selectFirst: true,
options: [
{label: '无', value: 'undefined'},
{label: 'b12', value: 'b12'},
{label: 'b1', value: 'b1'},
{label: 'b5', value: 'b5'},
{label: 'a4', value: 'a4'},
@@ -182,6 +183,7 @@ function toolTab() {
selectFirst: true,
options: [
{label: '无', value: 'undefined'},
{label: 'b12', value: 'b12'},
{label: 'b1', value: 'b1'},
{label: 'b5', value: 'b5'},
{label: 'a4', value: 'a4'},