This is an automated email from the ASF dual-hosted git repository. zhongjiajie pushed a commit to branch 3.2.0-release in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 60b9abba189ff4ebe6aac20e27876e585b08cc13 Author: dong6349 <[email protected]> AuthorDate: Tue Sep 19 10:34:07 2023 +0800 Fix the ephemeralId will not be deleted before jdbc-registry closed. (#14936) (cherry picked from commit 298b8ccf5a263e875568ce124b765b4789fa8061) --- .../plugin/registry/jdbc/task/EphemeralDateManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/task/EphemeralDateManager.java b/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/task/EphemeralDateManager.java index 02ef476240..64915e8ca8 100644 --- a/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/task/EphemeralDateManager.java +++ b/dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/task/EphemeralDateManager.java @@ -83,12 +83,12 @@ public class EphemeralDateManager implements AutoCloseable { @Override public void close() throws SQLException { - ephemeralDateIds.clear(); - connectionListeners.clear(); - scheduledExecutorService.shutdownNow(); for (Long ephemeralDateId : ephemeralDateIds) { jdbcOperator.deleteDataById(ephemeralDateId); } + ephemeralDateIds.clear(); + connectionListeners.clear(); + scheduledExecutorService.shutdownNow(); } // Use this task to refresh ephemeral term and check the connect state.
