You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by zh...@apache.org on 2023/10/11 08:06:25 UTC
[dolphinscheduler] 23/40: Fix the ephemeralId will not be deleted before jdbc-registry closed. (#14936)
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 <do...@163.com>
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.