diff --git a/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java b/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java index 995aa88..2faaa65 100644 --- a/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java +++ b/service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java @@ -152,10 +152,10 @@ public class OverviewController extends BaseController { @GetMapping("sync_running_status") public AmisMapResponse syncRunningStatus() { ImmutableList locks = zookeeperService.getChildren(NameHelper.ZK_SYNC_RUNNING_LOCK_PATH).collect(ZookeeperNode::getPath); - MutableList runningJob = Lists.mutable.empty(); - MutableList unRunningJob = Lists.mutable.empty(); - MutableList runningTable = Lists.mutable.empty(); - MutableList unRunningTable = Lists.mutable.empty(); + MutableList runningJob = Lists.mutable.empty().asSynchronized(); + MutableList unRunningJob = Lists.mutable.empty().asSynchronized(); + MutableList runningTable = Lists.mutable.empty().asSynchronized(); + MutableList unRunningTable = Lists.mutable.empty().asSynchronized(); ImmutableList idAliases = infoService.allFlinkJobIdAndAlias(); ImmutableList ids = idAliases.collect(JobIdAndAlias::getId).reject(ObjectUtil::isNull).distinct(); ids