This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch pyflink
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from aa0eff287 [Improve] pyflink improvement
add e60c86dd6 [Refactor] Refactor ApplicationService moving it to own
package and creating two interfaces. (#3009)
add 6a5e6e4e9 [Improve] Application service minor improvement (#3015)
add 9ca15a002 Merge branch 'dev' into pyflink
No new revisions were added by this update.
Summary of changes:
.../console/core/aspect/StreamParkAspect.java | 6 +-
.../core/controller/ApplicationController.java | 91 +-
.../controller/ApplicationHistoryController.java | 18 +-
.../core/controller/SavePointController.java | 6 +-
.../core/service/ApplicationBackUpService.java | 12 +-
.../console/core/service/ApplicationService.java | 128 --
.../service/alert/impl/AlertConfigServiceImpl.java | 6 +-
.../application/ApplicationActionService.java | 70 +
.../application/ApplicationInfoService.java | 238 +++
.../application/ApplicationManageService.java | 152 ++
.../impl/ApplicationActionServiceImpl.java | 749 ++++++++
.../impl/ApplicationInfoServiceImpl.java | 508 ++++++
.../impl/ApplicationManageServiceImpl.java | 778 ++++++++
.../core/service/impl/AppBuildPipeServiceImpl.java | 64 +-
.../service/impl/ApplicationBackUpServiceImpl.java | 72 +-
.../core/service/impl/ApplicationServiceImpl.java | 1860 --------------------
.../core/service/impl/ExternalLinkServiceImpl.java | 9 +-
.../core/service/impl/FlinkClusterServiceImpl.java | 9 +-
.../core/service/impl/FlinkEnvServiceImpl.java | 6 +-
.../core/service/impl/ProjectServiceImpl.java | 14 +-
.../core/service/impl/ResourceServiceImpl.java | 6 +-
.../core/service/impl/SavePointServiceImpl.java | 14 +-
.../core/service/impl/VariableServiceImpl.java | 8 +-
.../core/service/impl/YarnQueueServiceImpl.java | 6 +-
.../console/core/task/CheckpointProcessor.java | 6 +-
.../console/core/task/FlinkClusterWatcher.java | 8 +-
.../console/core/task/FlinkHttpWatcher.java | 26 +-
.../core/task/FlinkK8sChangeEventListener.java | 17 +-
.../console/core/task/FlinkK8sWatcherWrapper.java | 8 +-
.../system/service/impl/TeamServiceImpl.java | 6 +-
.../system/service/impl/UserServiceImpl.java | 11 +-
...est.java => ApplicationManageServiceITest.java} | 20 +-
...Test.java => ApplicationManageServiceTest.java} | 19 +-
.../console/core/service/SavePointServiceTest.java | 7 +-
.../console/core/service/UserServiceTest.java | 13 +-
.../console/core/service/YarnQueueServiceTest.java | 17 +-
36 files changed, 2744 insertions(+), 2244 deletions(-)
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ApplicationService.java
create mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/ApplicationActionService.java
create mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/ApplicationInfoService.java
create mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/ApplicationManageService.java
create mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
create mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
create mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
rename
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/{ApplicationServiceITest.java
=> ApplicationManageServiceITest.java} (86%)
rename
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/{ApplicationServiceTest.java
=> ApplicationManageServiceTest.java} (86%)
