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

feat(web): 任务执行前判断pulsar topic和url是否匹配

Browse Source
This commit is contained in:
兰缘小妖
2024-01-22 16:45:07 +08:00
parent b7bdd25bdc
commit 123c79787c
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/TaskController.java
View File

@@ -47,8 +47,14 @@ public class TaskController {
boolean scanQueue = StrUtil.contains(mode, "queue");
boolean scanLog = StrUtil.contains(mode, "log");
boolean scanBase = StrUtil.contains(mode, "base");
if (scanQueue && (StrUtil.isBlank(topic) || StrUtil.isBlank(pulsar))) {
throw new RuntimeException("Pulsar topic or url cannot be empty");
if (scanQueue) {
if (StrUtil.isBlank(topic) || StrUtil.isBlank(pulsar)) {
throw new RuntimeException("Pulsar topic or url cannot be empty");
} else {
if (!pulsarService.existsTopic(pulsar, topic)) {
throw new RuntimeException("Pulsar url is not contain the topic");
}
}
}
if ((scanLog || scanBase) && StrUtil.isBlank(hdfs)) {
throw new RuntimeException("Hdfs path cannot be empty");