This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch spark-ui
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from dc5b67eaf [Improve] Applications Name rename to Job Name
add c950062e0 [Improve] registry module adjustment
No new revisions were added by this update.
Summary of changes:
pom.xml | 11 -------
.../streampark-console-registry/pom.xml | 5 +--
.../streampark-registry-all/pom.xml | 36 ----------------------
.../streampark-registry-api/pom.xml | 2 ++
.../README.md | 0
.../pom.xml | 6 ++--
.../plugin/registry/core}/JdbcRegistry.java | 14 ++++-----
.../core}/JdbcRegistryAutoConfiguration.java | 22 ++++++-------
.../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 | 18 +++++------
.../core}/client/JdbcRegistryClientIdentify.java | 2 +-
.../mapper/JdbcRegistryClientHeartbeatMapper.java | 4 +--
.../mapper/JdbcRegistryDataChanceEventMapper.java | 4 +--
.../core}/mapper/JdbcRegistryDataMapper.java | 4 +--
.../core}/mapper/JdbcRegistryLockMapper.java | 4 +--
.../model/DO/JdbcRegistryClientHeartbeat.java | 2 +-
.../registry/core}/model/DO/JdbcRegistryData.java | 2 +-
.../model/DO/JdbcRegistryDataChanceEvent.java | 2 +-
.../registry/core}/model/DO/JdbcRegistryLock.java | 2 +-
.../plugin/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 | 10 +++---
.../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 +-
.../src/main/resources/mysql_registry_init.sql | 0
.../main/resources/postgresql_registry_init.sql | 0
.../registry/core}/JdbcRegistryTestCase.java | 4 +--
.../core}/JdbcRegistryThreadFactoryTest.java | 2 +-
.../plugin/registry/core}/LockUtilsTest.java | 2 +-
.../registry/core}/MysqlJdbcRegistryTestCase.java | 2 +-
.../core}/PostgresqlJdbcRegistryTestCase.java | 2 +-
.../src/test/resources/application-mysql.yaml | 0
.../src/test/resources/application-postgresql.yaml | 0
.../src/test/resources/application.yaml | 0
.../src/test/resources/logback.xml | 0
.../streampark-registry-it/pom.xml | 3 +-
.../plugin/registry/RegistryTestCase.java | 0
.../streampark-registry-plugins/pom.xml | 35 ---------------------
.../streampark-console-service/pom.xml | 3 +-
57 files changed, 135 insertions(+), 212 deletions(-)
delete mode 100644
streampark-console/streampark-console-registry/streampark-registry-all/pom.xml
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/README.md (100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/pom.xml (95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/JdbcRegistry.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/JdbcRegistryAutoConfiguration.java
(88%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/JdbcRegistryProperties.java
(98%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/JdbcRegistryThreadFactory.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/LockUtils.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/client/IJdbcRegistryClient.java
(91%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/client/JdbcRegistryClient.java
(88%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/client/JdbcRegistryClientIdentify.java
(94%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/mapper/JdbcRegistryClientHeartbeatMapper.java
(90%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/mapper/JdbcRegistryDataChanceEventMapper.java
(93%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/mapper/JdbcRegistryDataMapper.java
(93%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/mapper/JdbcRegistryLockMapper.java
(92%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DO/JdbcRegistryClientHeartbeat.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DO/JdbcRegistryData.java
(96%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DO/JdbcRegistryDataChanceEvent.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DO/JdbcRegistryLock.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DTO/DataType.java
(93%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DTO/JdbcRegistryClientHeartbeatDTO.java
(96%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DTO/JdbcRegistryDataChanceEventDTO.java
(93%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DTO/JdbcRegistryDataDTO.java
(94%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/model/DTO/JdbcRegistryLockDTO.java
(94%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/repository/JdbcRegistryClientRepository.java
(90%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/repository/JdbcRegistryDataChanceEventRepository.java
(91%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/repository/JdbcRegistryDataRepository.java
(88%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/repository/JdbcRegistryLockRepository.java
(88%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/ConnectionStateListener.java
(94%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/IJdbcRegistryDataManager.java
(91%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/IJdbcRegistryLockManager.java
(96%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/IJdbcRegistryServer.java
(92%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/IRegistryRowChangeNotifier.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/JdbcRegistryDataChangeListener.java
(94%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/JdbcRegistryDataManager.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/JdbcRegistryLockManager.java
(94%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/JdbcRegistryServer.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/main/java/org/apache/streampark/plugin/registry/core}/server/JdbcRegistryServerState.java
(93%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/main/resources/META-INF/spring.factories (93%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/main/resources/mysql_registry_init.sql (100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/main/resources/postgresql_registry_init.sql
(100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/test/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core}/JdbcRegistryTestCase.java
(95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/test/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core}/JdbcRegistryThreadFactoryTest.java
(97%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/test/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core}/LockUtilsTest.java
(96%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/test/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core}/MysqlJdbcRegistryTestCase.java
(98%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc/src/test/java/org/apache/streampark/plugin/registry/jdbc
=>
streampark-registry-core/src/test/java/org/apache/streampark/plugin/registry/core}/PostgresqlJdbcRegistryTestCase.java
(98%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/test/resources/application-mysql.yaml (100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/test/resources/application-postgresql.yaml
(100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/test/resources/application.yaml (100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins/streampark-registry-jdbc
=> streampark-registry-core}/src/test/resources/logback.xml (100%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins =>
}/streampark-registry-it/pom.xml (95%)
rename
streampark-console/streampark-console-registry/{streampark-registry-plugins =>
}/streampark-registry-it/src/test/java/org/apache/streampark/plugin/registry/RegistryTestCase.java
(100%)
delete mode 100644
streampark-console/streampark-console-registry/streampark-registry-plugins/pom.xml
