diff --git a/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/ScheduleController.java b/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/ScheduleController.java index 61e20a1..aef261d 100644 --- a/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/ScheduleController.java +++ b/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/ScheduleController.java @@ -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(); } } diff --git a/service-web/src/main/resources/static/components/tool-tab.js b/service-web/src/main/resources/static/components/tool-tab.js index 0a7b334..ede3325 100644 --- a/service-web/src/main/resources/static/components/tool-tab.js +++ b/service-web/src/main/resources/static/components/tool-tab.js @@ -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'},