From 692228183d8ae53daebd572f2e09481681665a7d Mon Sep 17 00:00:00 2001 From: taojinlong Date: Tue, 26 Nov 2024 18:46:20 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=BA=90=E5=AE=9A=E6=97=B6=E5=90=8C=E6=AD=A5=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datasource/server/DatasourceServer.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java index d1b4912d6f..7019a45686 100644 --- a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java +++ b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java @@ -989,16 +989,16 @@ public class DatasourceServer implements DatasourceApi { datasources.forEach(datasource -> { if (!syncDsIds.contains(datasource.getId())) { syncDsIds.add(datasource.getId()); + commonThreadPool.addTask(() -> { + try { + LicenseUtil.validate(); + validate(datasource); + } catch (Exception e) { + } finally { + syncDsIds.removeIf(id -> id.equals(datasource.getId())); + } + }); } - commonThreadPool.addTask(() -> { - try { - LicenseUtil.validate(); - validate(datasource); - } catch (Exception e) { - } finally { - syncDsIds.removeIf(id -> id.equals(datasource.getId())); - } - }); }); }