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

fix(web): 修复running_status接口由于多线程导致数组越界

Browse Source
This commit is contained in:
兰缘小妖
2024-01-12 15:06:14 +08:00
parent c6e0a681bc
commit 783c05f6da
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java
View File

@@ -152,10 +152,10 @@ public class OverviewController extends BaseController {
@GetMapping("sync_running_status")
public AmisMapResponse syncRunningStatus() {
ImmutableList<String> locks = zookeeperService.getChildren(NameHelper.ZK_SYNC_RUNNING_LOCK_PATH).collect(ZookeeperNode::getPath);
MutableList<JobIdAndAlias> runningJob = Lists.mutable.empty();
MutableList<JobIdAndAlias> unRunningJob = Lists.mutable.empty();
MutableList<JobIdAndAlias> runningTable = Lists.mutable.empty();
MutableList<JobIdAndAlias> unRunningTable = Lists.mutable.empty();
MutableList<JobIdAndAlias> runningJob = Lists.mutable.<JobIdAndAlias>empty().asSynchronized();
MutableList<JobIdAndAlias> unRunningJob = Lists.mutable.<JobIdAndAlias>empty().asSynchronized();
MutableList<JobIdAndAlias> runningTable = Lists.mutable.<JobIdAndAlias>empty().asSynchronized();
MutableList<JobIdAndAlias> unRunningTable = Lists.mutable.<JobIdAndAlias>empty().asSynchronized();
ImmutableList<JobIdAndAlias> idAliases = infoService.allFlinkJobIdAndAlias();
ImmutableList<Long> ids = idAliases.collect(JobIdAndAlias::getId).reject(ObjectUtil::isNull).distinct();
ids