From 783c05f6da314a7960a05d3ad5e4fd85622c2ee2 Mon Sep 17 00:00:00 2001
From: lanyuanxiaoyao <lanyuanxiaoyao@gmail.com>
Date: Fri, 12 Jan 2024 15:06:14 +0800
Subject: [PATCH] =?UTF-8?q?fix(web):=20=E4=BF=AE=E5=A4=8Drunning=5Fstatus?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E7=94=B1=E4=BA=8E=E5=A4=9A=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E5=AF=BC=E8=87=B4=E6=95=B0=E7=BB=84=E8=B6=8A=E7=95=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/web/controller/OverviewController.java        | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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<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