This is an automated email from the ASF dual-hosted git repository.
chengjie pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 360ae5ac2 [Improve] Adjust the package name of the console-registry
module. (#4093)
360ae5ac2 is described below
commit 360ae5ac2d0abab51178a3bc7e1e446413b1c289
Author: benjobs <[email protected]>
AuthorDate: Thu Sep 26 15:07:42 2024 +0800
[Improve] Adjust the package name of the console-registry module. (#4093)
* [Improve] spark app submit bug fixed.
* [Improve] known-dependencies.txt updated
* [Improve] Adjust the package name of the console-registry module.
---
.../{plugin => }/registry/core/JdbcRegistry.java | 14 ++++++------
.../core/JdbcRegistryAutoConfiguration.java | 24 ++++++++++----------
.../registry/core/JdbcRegistryProperties.java | 2 +-
.../registry/core/JdbcRegistryThreadFactory.java | 2 +-
.../{plugin => }/registry/core/LockUtils.java | 2 +-
.../registry/core/client/IJdbcRegistryClient.java | 10 ++++-----
.../registry/core/client/JdbcRegistryClient.java | 19 ++++++++--------
.../core/client/JdbcRegistryClientIdentify.java | 2 +-
.../mapper/JdbcRegistryClientHeartbeatMapper.java | 4 ++--
.../mapper/JdbcRegistryDataChanceEventMapper.java | 4 ++--
.../core/mapper/JdbcRegistryDataMapper.java | 4 ++--
.../core/mapper/JdbcRegistryLockMapper.java | 4 ++--
.../core/model/DO/JdbcRegistryClientHeartbeat.java | 2 +-
.../registry/core/model/DO/JdbcRegistryData.java | 2 +-
.../core/model/DO/JdbcRegistryDataChanceEvent.java | 2 +-
.../registry/core/model/DO/JdbcRegistryLock.java | 2 +-
.../registry/core/model/DTO/DataType.java | 2 +-
.../model/DTO/JdbcRegistryClientHeartbeatDTO.java | 4 ++--
.../model/DTO/JdbcRegistryDataChanceEventDTO.java | 6 ++---
.../core/model/DTO/JdbcRegistryDataDTO.java | 4 ++--
.../core/model/DTO/JdbcRegistryLockDTO.java | 4 ++--
.../repository/JdbcRegistryClientRepository.java | 8 +++----
.../JdbcRegistryDataChanceEventRepository.java | 8 +++----
.../repository/JdbcRegistryDataRepository.java | 10 ++++-----
.../repository/JdbcRegistryLockRepository.java | 8 +++----
.../core/server/ConnectionStateListener.java | 2 +-
.../core/server/IJdbcRegistryDataManager.java | 6 ++---
.../core/server/IJdbcRegistryLockManager.java | 2 +-
.../registry/core/server/IJdbcRegistryServer.java | 11 ++++-----
.../core/server/IRegistryRowChangeNotifier.java | 2 +-
.../server/JdbcRegistryDataChangeListener.java | 2 +-
.../core/server/JdbcRegistryDataManager.java | 18 +++++++--------
.../core/server/JdbcRegistryLockManager.java | 10 ++++-----
.../registry/core/server/JdbcRegistryServer.java | 26 +++++++++++-----------
.../core/server/JdbcRegistryServerState.java | 4 ++--
.../src/main/resources/META-INF/spring.factories | 2 +-
.../registry/core/JdbcRegistryTestCase.java | 6 ++---
.../core/JdbcRegistryThreadFactoryTest.java | 2 +-
.../{plugin => }/registry/core/LockUtilsTest.java | 2 +-
.../registry/core/MysqlJdbcRegistryTestCase.java | 2 +-
.../core/PostgresqlJdbcRegistryTestCase.java | 2 +-
.../plugin/registry/RegistryTestCase.java | 2 +-
42 files changed, 128 insertions(+), 126 deletions(-)
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistry.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistry.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistry.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistry.java
index c04d49f75..58f5f972e 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistry.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistry.java
@@ -15,20 +15,20 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
-import org.apache.streampark.plugin.registry.core.client.JdbcRegistryClient;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
-import
org.apache.streampark.plugin.registry.core.server.ConnectionStateListener;
-import org.apache.streampark.plugin.registry.core.server.IJdbcRegistryServer;
-import
org.apache.streampark.plugin.registry.core.server.JdbcRegistryDataChangeListener;
import org.apache.streampark.registry.api.ConnectionListener;
import org.apache.streampark.registry.api.ConnectionState;
import org.apache.streampark.registry.api.Event;
import org.apache.streampark.registry.api.Registry;
import org.apache.streampark.registry.api.RegistryException;
import org.apache.streampark.registry.api.SubscribeListener;
+import org.apache.streampark.registry.core.client.JdbcRegistryClient;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
+import org.apache.streampark.registry.core.server.ConnectionStateListener;
+import org.apache.streampark.registry.core.server.IJdbcRegistryServer;
+import
org.apache.streampark.registry.core.server.JdbcRegistryDataChangeListener;
import org.apache.commons.lang3.StringUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryAutoConfiguration.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryAutoConfiguration.java
similarity index 84%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryAutoConfiguration.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryAutoConfiguration.java
index e2d10447e..bb6799055 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryAutoConfiguration.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryAutoConfiguration.java
@@ -15,18 +15,18 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryClientHeartbeatMapper;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryDataChanceEventMapper;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryDataMapper;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryLockMapper;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryClientRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryDataChanceEventRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryDataRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryLockRepository;
-import org.apache.streampark.plugin.registry.core.server.IJdbcRegistryServer;
-import org.apache.streampark.plugin.registry.core.server.JdbcRegistryServer;
+import
org.apache.streampark.registry.core.mapper.JdbcRegistryClientHeartbeatMapper;
+import
org.apache.streampark.registry.core.mapper.JdbcRegistryDataChanceEventMapper;
+import org.apache.streampark.registry.core.mapper.JdbcRegistryDataMapper;
+import org.apache.streampark.registry.core.mapper.JdbcRegistryLockMapper;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryClientRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryDataChanceEventRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryDataRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryLockRepository;
+import org.apache.streampark.registry.core.server.IJdbcRegistryServer;
+import org.apache.streampark.registry.core.server.JdbcRegistryServer;
import org.apache.ibatis.session.SqlSessionFactory;
@@ -46,7 +46,7 @@ import org.springframework.context.annotation.Configuration;
@Slf4j
@ComponentScan
@Configuration(proxyBeanMethods = false)
-@MapperScan("org.apache.streampark.plugin.registry.jdbc.mapper")
+@MapperScan("org.apache.streampark.registry.core.mapper")
@ConditionalOnProperty(prefix = "registry", name = "type", havingValue =
"jdbc")
@AutoConfigureAfter(MybatisPlusAutoConfiguration.class)
public class JdbcRegistryAutoConfiguration {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryProperties.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryProperties.java
similarity index 98%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryProperties.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryProperties.java
index ad64575b0..e7ed5baa6 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryProperties.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryProperties.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.common.utils.NetworkUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryThreadFactory.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryThreadFactory.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryThreadFactory.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryThreadFactory.java
index e5a527d22..8b004c640 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/JdbcRegistryThreadFactory.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/JdbcRegistryThreadFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.registry.api.thread.ThreadUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/LockUtils.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/LockUtils.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/LockUtils.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/LockUtils.java
index 5a873ceff..0f4f86c18 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/LockUtils.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/LockUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.common.utils.NetworkUtils;
import org.apache.streampark.common.utils.OSUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/IJdbcRegistryClient.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/IJdbcRegistryClient.java
similarity index 89%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/IJdbcRegistryClient.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/IJdbcRegistryClient.java
index 54d66b4e8..b6f487090 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/IJdbcRegistryClient.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/IJdbcRegistryClient.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.client;
+package org.apache.streampark.registry.core.client;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
-import
org.apache.streampark.plugin.registry.core.server.ConnectionStateListener;
-import
org.apache.streampark.plugin.registry.core.server.JdbcRegistryDataChangeListener;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
+import org.apache.streampark.registry.core.server.ConnectionStateListener;
+import
org.apache.streampark.registry.core.server.JdbcRegistryDataChangeListener;
import java.util.List;
import java.util.Optional;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/JdbcRegistryClient.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/JdbcRegistryClient.java
similarity index 86%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/JdbcRegistryClient.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/JdbcRegistryClient.java
index 81e75bb1b..2775953e7 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/JdbcRegistryClient.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/JdbcRegistryClient.java
@@ -15,18 +15,19 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.client;
+package org.apache.streampark.registry.core.client;
import org.apache.streampark.common.utils.NetworkUtils;
import org.apache.streampark.common.utils.OSUtils;
import org.apache.streampark.common.utils.UUIDUtils;
-import org.apache.streampark.plugin.registry.core.JdbcRegistryProperties;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
-import
org.apache.streampark.plugin.registry.core.server.ConnectionStateListener;
-import org.apache.streampark.plugin.registry.core.server.IJdbcRegistryServer;
-import
org.apache.streampark.plugin.registry.core.server.JdbcRegistryDataChangeListener;
-import
org.apache.streampark.plugin.registry.core.server.JdbcRegistryServerState;
+import org.apache.streampark.registry.core.JdbcRegistryProperties;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
+import org.apache.streampark.registry.core.server.ConnectionStateListener;
+import org.apache.streampark.registry.core.server.IJdbcRegistryServer;
+import
org.apache.streampark.registry.core.server.JdbcRegistryDataChangeListener;
+import org.apache.streampark.registry.core.server.JdbcRegistryServer;
+import org.apache.streampark.registry.core.server.JdbcRegistryServerState;
import lombok.extern.slf4j.Slf4j;
@@ -34,7 +35,7 @@ import java.util.List;
import java.util.Optional;
/**
- * The client of jdbc registry, used to interact with the {@link
org.apache.streampark.plugin.registry.core.server.JdbcRegistryServer}.
+ * The client of jdbc registry, used to interact with the {@link
JdbcRegistryServer}.
*/
@Slf4j
public class JdbcRegistryClient implements IJdbcRegistryClient {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/JdbcRegistryClientIdentify.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/JdbcRegistryClientIdentify.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/JdbcRegistryClientIdentify.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/JdbcRegistryClientIdentify.java
index 3ca20cb51..7481c3a30 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/client/JdbcRegistryClientIdentify.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/client/JdbcRegistryClientIdentify.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.client;
+package org.apache.streampark.registry.core.client;
import lombok.AllArgsConstructor;
import lombok.Getter;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryClientHeartbeatMapper.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryClientHeartbeatMapper.java
similarity index 88%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryClientHeartbeatMapper.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryClientHeartbeatMapper.java
index cbcfefae4..f1a27c299 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryClientHeartbeatMapper.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryClientHeartbeatMapper.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.mapper;
+package org.apache.streampark.registry.core.mapper;
-import
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryClientHeartbeat;
+import
org.apache.streampark.registry.core.model.DO.JdbcRegistryClientHeartbeat;
import org.apache.ibatis.annotations.Select;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryDataChanceEventMapper.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryDataChanceEventMapper.java
similarity index 91%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryDataChanceEventMapper.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryDataChanceEventMapper.java
index 2563e90db..b66982ed9 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryDataChanceEventMapper.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryDataChanceEventMapper.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.mapper;
+package org.apache.streampark.registry.core.mapper;
-import
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryDataChanceEvent;
+import
org.apache.streampark.registry.core.model.DO.JdbcRegistryDataChanceEvent;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryDataMapper.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryDataMapper.java
similarity index 93%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryDataMapper.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryDataMapper.java
index 014a1862d..c0eb45dff 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryDataMapper.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryDataMapper.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.mapper;
+package org.apache.streampark.registry.core.mapper;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryData;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryData;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryLockMapper.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryLockMapper.java
similarity index 91%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryLockMapper.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryLockMapper.java
index 58a23b03c..84f8d7e45 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/mapper/JdbcRegistryLockMapper.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/mapper/JdbcRegistryLockMapper.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.mapper;
+package org.apache.streampark.registry.core.mapper;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryLock;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryLock;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryClientHeartbeat.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryClientHeartbeat.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryClientHeartbeat.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryClientHeartbeat.java
index 689c66b07..018a867de 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryClientHeartbeat.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryClientHeartbeat.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DO;
+package org.apache.streampark.registry.core.model.DO;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryData.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryData.java
similarity index 96%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryData.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryData.java
index b8c0ef74d..8a363aec2 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryData.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DO;
+package org.apache.streampark.registry.core.model.DO;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryDataChanceEvent.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryDataChanceEvent.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryDataChanceEvent.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryDataChanceEvent.java
index 179a94cdb..4ebce10e5 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryDataChanceEvent.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryDataChanceEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DO;
+package org.apache.streampark.registry.core.model.DO;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryLock.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryLock.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryLock.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryLock.java
index 97f393b77..19dd87321 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DO/JdbcRegistryLock.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DO/JdbcRegistryLock.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DO;
+package org.apache.streampark.registry.core.model.DO;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/DataType.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/DataType.java
similarity index 93%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/DataType.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/DataType.java
index 83e76752a..cd33dc186 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/DataType.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/DataType.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DTO;
+package org.apache.streampark.registry.core.model.DTO;
public enum DataType {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryClientHeartbeatDTO.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryClientHeartbeatDTO.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryClientHeartbeatDTO.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryClientHeartbeatDTO.java
index 234ef2137..98957864d 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryClientHeartbeatDTO.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryClientHeartbeatDTO.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DTO;
+package org.apache.streampark.registry.core.model.DTO;
import org.apache.streampark.common.utils.JSONUtils;
-import
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryClientHeartbeat;
+import
org.apache.streampark.registry.core.model.DO.JdbcRegistryClientHeartbeat;
import lombok.AllArgsConstructor;
import lombok.Builder;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryDataChanceEventDTO.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryDataChanceEventDTO.java
similarity index 92%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryDataChanceEventDTO.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryDataChanceEventDTO.java
index 173a12d5d..721ff66d8 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryDataChanceEventDTO.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryDataChanceEventDTO.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DTO;
+package org.apache.streampark.registry.core.model.DTO;
import org.apache.streampark.common.utils.JSONUtils;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryData;
-import
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryDataChanceEvent;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryData;
+import
org.apache.streampark.registry.core.model.DO.JdbcRegistryDataChanceEvent;
import lombok.AllArgsConstructor;
import lombok.Builder;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryDataDTO.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryDataDTO.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryDataDTO.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryDataDTO.java
index 8a6433885..85d3eb685 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryDataDTO.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryDataDTO.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DTO;
+package org.apache.streampark.registry.core.model.DTO;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryData;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryData;
import lombok.AllArgsConstructor;
import lombok.Builder;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryLockDTO.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryLockDTO.java
similarity index 93%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryLockDTO.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryLockDTO.java
index 0755654e5..0404d632a 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/model/DTO/JdbcRegistryLockDTO.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/model/DTO/JdbcRegistryLockDTO.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.model.DTO;
+package org.apache.streampark.registry.core.model.DTO;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryLock;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryLock;
import lombok.AllArgsConstructor;
import lombok.Builder;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryClientRepository.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryClientRepository.java
similarity index 88%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryClientRepository.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryClientRepository.java
index 38c1ce540..c3ae1797b 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryClientRepository.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryClientRepository.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.repository;
+package org.apache.streampark.registry.core.repository;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryClientHeartbeatMapper;
-import
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryClientHeartbeat;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryClientHeartbeatDTO;
+import
org.apache.streampark.registry.core.mapper.JdbcRegistryClientHeartbeatMapper;
+import
org.apache.streampark.registry.core.model.DO.JdbcRegistryClientHeartbeat;
+import
org.apache.streampark.registry.core.model.DTO.JdbcRegistryClientHeartbeatDTO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryDataChanceEventRepository.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryDataChanceEventRepository.java
similarity index 88%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryDataChanceEventRepository.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryDataChanceEventRepository.java
index 707b90825..489443827 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryDataChanceEventRepository.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryDataChanceEventRepository.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.repository;
+package org.apache.streampark.registry.core.repository;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryDataChanceEventMapper;
-import
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryDataChanceEvent;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataChanceEventDTO;
+import
org.apache.streampark.registry.core.mapper.JdbcRegistryDataChanceEventMapper;
+import
org.apache.streampark.registry.core.model.DO.JdbcRegistryDataChanceEvent;
+import
org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataChanceEventDTO;
import org.springframework.stereotype.Repository;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryDataRepository.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryDataRepository.java
similarity index 86%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryDataRepository.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryDataRepository.java
index a680c19f2..0ceedafb1 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryDataRepository.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryDataRepository.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.repository;
+package org.apache.streampark.registry.core.repository;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryDataMapper;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryData;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
+import org.apache.streampark.registry.core.mapper.JdbcRegistryDataMapper;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryData;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryLockRepository.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryLockRepository.java
similarity index 85%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryLockRepository.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryLockRepository.java
index 2a994950c..b9771bc44 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/repository/JdbcRegistryLockRepository.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/repository/JdbcRegistryLockRepository.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.repository;
+package org.apache.streampark.registry.core.repository;
-import
org.apache.streampark.plugin.registry.core.mapper.JdbcRegistryLockMapper;
-import org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryLock;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryLockDTO;
+import org.apache.streampark.registry.core.mapper.JdbcRegistryLockMapper;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryLock;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryLockDTO;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/ConnectionStateListener.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/ConnectionStateListener.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/ConnectionStateListener.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/ConnectionStateListener.java
index e3231276c..e0053c797 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/ConnectionStateListener.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/ConnectionStateListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
public interface ConnectionStateListener {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryDataManager.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryDataManager.java
similarity index 90%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryDataManager.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryDataManager.java
index 7bb17ea23..4ecca0738 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryDataManager.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryDataManager.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
import java.util.List;
import java.util.Optional;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryLockManager.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryLockManager.java
similarity index 96%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryLockManager.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryLockManager.java
index 72cf92972..7d8f9d291 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryLockManager.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryLockManager.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
public interface IJdbcRegistryLockManager {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryServer.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryServer.java
similarity index 90%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryServer.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryServer.java
index 61ef78f19..3f03e7460 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IJdbcRegistryServer.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IJdbcRegistryServer.java
@@ -15,11 +15,12 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
-import org.apache.streampark.plugin.registry.core.client.IJdbcRegistryClient;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
+import org.apache.streampark.registry.core.client.IJdbcRegistryClient;
+import org.apache.streampark.registry.core.model.DO.JdbcRegistryData;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
import java.util.List;
import java.util.Optional;
@@ -52,7 +53,7 @@ public interface IJdbcRegistryServer extends AutoCloseable {
void subscribeConnectionStateChange(ConnectionStateListener
connectionStateListener);
/**
- * Subscribe the {@link
org.apache.streampark.plugin.registry.core.model.DO.JdbcRegistryData} change.
+ * Subscribe the {@link JdbcRegistryData} change.
*/
void subscribeJdbcRegistryDataChange(JdbcRegistryDataChangeListener
jdbcRegistryDataChangeListener);
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IRegistryRowChangeNotifier.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IRegistryRowChangeNotifier.java
similarity index 95%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IRegistryRowChangeNotifier.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IRegistryRowChangeNotifier.java
index 563d2b5c1..723f63103 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/IRegistryRowChangeNotifier.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/IRegistryRowChangeNotifier.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
public interface IRegistryRowChangeNotifier<T> {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryDataChangeListener.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryDataChangeListener.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryDataChangeListener.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryDataChangeListener.java
index ae55ad51e..015219ea8 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryDataChangeListener.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryDataChangeListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
public interface JdbcRegistryDataChangeListener {
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryDataManager.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryDataManager.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryDataManager.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryDataManager.java
index 1e15458c1..1b2ef8c49 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryDataManager.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryDataManager.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
-
-import org.apache.streampark.plugin.registry.core.JdbcRegistryProperties;
-import org.apache.streampark.plugin.registry.core.JdbcRegistryThreadFactory;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataChanceEventDTO;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryDataChanceEventRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryDataRepository;
+package org.apache.streampark.registry.core.server;
+
+import org.apache.streampark.registry.core.JdbcRegistryProperties;
+import org.apache.streampark.registry.core.JdbcRegistryThreadFactory;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import
org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataChanceEventDTO;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryDataChanceEventRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryDataRepository;
import org.apache.commons.lang3.time.DateUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryLockManager.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryLockManager.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryLockManager.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryLockManager.java
index 28aa0e9cd..0a9ce84d2 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryLockManager.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryLockManager.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
-import org.apache.streampark.plugin.registry.core.JdbcRegistryProperties;
-import org.apache.streampark.plugin.registry.core.LockUtils;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryLockDTO;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryLockRepository;
import org.apache.streampark.registry.api.thread.ThreadUtils;
+import org.apache.streampark.registry.core.JdbcRegistryProperties;
+import org.apache.streampark.registry.core.LockUtils;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryLockDTO;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryLockRepository;
import lombok.AllArgsConstructor;
import lombok.Builder;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryServer.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryServer.java
similarity index 94%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryServer.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryServer.java
index a09898b9b..596cbe58e 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryServer.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryServer.java
@@ -15,20 +15,20 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
-
-import org.apache.streampark.plugin.registry.core.JdbcRegistryProperties;
-import org.apache.streampark.plugin.registry.core.JdbcRegistryThreadFactory;
-import org.apache.streampark.plugin.registry.core.client.IJdbcRegistryClient;
-import
org.apache.streampark.plugin.registry.core.client.JdbcRegistryClientIdentify;
-import org.apache.streampark.plugin.registry.core.model.DTO.DataType;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryClientHeartbeatDTO;
-import
org.apache.streampark.plugin.registry.core.model.DTO.JdbcRegistryDataDTO;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryClientRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryDataChanceEventRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryDataRepository;
-import
org.apache.streampark.plugin.registry.core.repository.JdbcRegistryLockRepository;
+package org.apache.streampark.registry.core.server;
+
import org.apache.streampark.registry.api.RegistryException;
+import org.apache.streampark.registry.core.JdbcRegistryProperties;
+import org.apache.streampark.registry.core.JdbcRegistryThreadFactory;
+import org.apache.streampark.registry.core.client.IJdbcRegistryClient;
+import org.apache.streampark.registry.core.client.JdbcRegistryClientIdentify;
+import org.apache.streampark.registry.core.model.DTO.DataType;
+import
org.apache.streampark.registry.core.model.DTO.JdbcRegistryClientHeartbeatDTO;
+import org.apache.streampark.registry.core.model.DTO.JdbcRegistryDataDTO;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryClientRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryDataChanceEventRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryDataRepository;
+import
org.apache.streampark.registry.core.repository.JdbcRegistryLockRepository;
import org.apache.commons.collections4.CollectionUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryServerState.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryServerState.java
similarity index 92%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryServerState.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryServerState.java
index eaf40cf29..e568e7d8a 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core/server/JdbcRegistryServerState.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/java/org/apache/streampark/registry/core/server/JdbcRegistryServerState.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core.server;
+package org.apache.streampark.registry.core.server;
-import org.apache.streampark.plugin.registry.core.JdbcRegistryProperties;
+import org.apache.streampark.registry.core.JdbcRegistryProperties;
public enum JdbcRegistryServerState {
/**
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/resources/META-INF/spring.factories
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/resources/META-INF/spring.factories
index 95435421f..a4f56a18a 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/main/resources/META-INF/spring.factories
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/main/resources/META-INF/spring.factories
@@ -16,4 +16,4 @@
#
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
- org.apache.streampark.plugin.registry.core.JdbcRegistryAutoConfiguration
+ org.apache.streampark.registry.core.JdbcRegistryAutoConfiguration
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/JdbcRegistryTestCase.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/JdbcRegistryTestCase.java
similarity index 92%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/JdbcRegistryTestCase.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/JdbcRegistryTestCase.java
index 4450622a2..75b876d38 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/JdbcRegistryTestCase.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/JdbcRegistryTestCase.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.common.CommonConfiguration;
-import org.apache.streampark.plugin.registry.RegistryTestCase;
-import org.apache.streampark.plugin.registry.core.server.IJdbcRegistryServer;
+import org.apache.streampark.registry.RegistryTestCase;
import org.apache.streampark.registry.api.ConnectionState;
+import org.apache.streampark.registry.core.server.IJdbcRegistryServer;
import lombok.SneakyThrows;
import org.junit.jupiter.api.Test;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/JdbcRegistryThreadFactoryTest.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/JdbcRegistryThreadFactoryTest.java
similarity index 97%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/JdbcRegistryThreadFactoryTest.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/JdbcRegistryThreadFactoryTest.java
index 1059f0c0f..6686d3987 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/JdbcRegistryThreadFactoryTest.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/JdbcRegistryThreadFactoryTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.junit.jupiter.api.Test;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/LockUtilsTest.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/LockUtilsTest.java
similarity index 96%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/LockUtilsTest.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/LockUtilsTest.java
index 93be619a5..7d2b98e46 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/LockUtilsTest.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/LockUtilsTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.common.utils.NetworkUtils;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/MysqlJdbcRegistryTestCase.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/MysqlJdbcRegistryTestCase.java
similarity index 98%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/MysqlJdbcRegistryTestCase.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/MysqlJdbcRegistryTestCase.java
index a5f7ec3f2..262df31d4 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/MysqlJdbcRegistryTestCase.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/MysqlJdbcRegistryTestCase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.registry.api.sql.SqlScriptRunner;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/PostgresqlJdbcRegistryTestCase.java
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/PostgresqlJdbcRegistryTestCase.java
similarity index 98%
rename from
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/PostgresqlJdbcRegistryTestCase.java
rename to
streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/PostgresqlJdbcRegistryTestCase.java
index 5784b2c3a..1e87d284c 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core/PostgresqlJdbcRegistryTestCase.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-core/src/test/java/org/apache/streampark/registry/core/PostgresqlJdbcRegistryTestCase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry.core;
+package org.apache.streampark.registry.core;
import org.apache.streampark.registry.api.sql.SqlScriptRunner;
diff --git
a/streampark-console/streampark-console-registry/streampark-registry-it/src/test/java/org/apache/streampark/plugin/registry/RegistryTestCase.java
b/streampark-console/streampark-console-registry/streampark-registry-it/src/test/java/org/apache/streampark/plugin/registry/RegistryTestCase.java
index 79fa530be..63ec42936 100644
---
a/streampark-console/streampark-console-registry/streampark-registry-it/src/test/java/org/apache/streampark/plugin/registry/RegistryTestCase.java
+++
b/streampark-console/streampark-console-registry/streampark-registry-it/src/test/java/org/apache/streampark/plugin/registry/RegistryTestCase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.plugin.registry;
+package org.apache.streampark.registry;
import org.apache.streampark.common.utils.NetworkUtils;
import org.apache.streampark.registry.api.ConnectionState;
