This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch package
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from 2bf7e34b8 [Improve] clone project minor improvement
add 63e178707 [Improve] Improve streampark-common module base on [3.9 Java
Streams] (#3174)
add 027172c17 [Improve] optimize enum RestoreMode getName function (#3173)
add d2a10d604 [Improve] Streampark-common module tika dependency moved to
the streampark-console module (#3171)
add 16d39f931 [Fix] Modify the isPythonFileType parameter (#3176)
add 436b9f320 Naming standardization (#3177)
add 2274d5502 [Improve] Unified Naming Rules for Enumeration Classes
(#3133) (#3175)
add 093a57dd5 [Improve] Enumeration improvement (#3182)
new 41b6541a6 Merge branch 'dev' of github.com:apache/incubator-streampark
into package
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
dist-material/release-docs/LICENSE | 1 +
streampark-common/pom.xml | 7 -
...elopmentMode.java => FlinkDevelopmentMode.java} | 12 +-
...{ExecutionMode.java => FlinkExecutionMode.java} | 32 ++--
.../{RestoreMode.java => FlinkRestoreMode.java} | 17 +-
.../apache/streampark/common/enums/ApiType.scala | 2 +-
.../streampark/common/enums/PlannerType.scala | 2 +-
.../apache/streampark/common/enums/TableMode.scala | 2 +-
.../apache/streampark/common/util/FileUtils.scala | 20 ---
.../streampark-console-service/pom.xml | 7 +
.../interceptor/UploadFileTypeInterceptor.java | 35 +++-
.../streampark/console/base/util/GitUtils.java | 6 +-
.../console/core/annotation/AppUpdated.java | 6 +-
.../console/core/annotation/PermissionAction.java | 4 +-
.../{StreamParkAspect.java => ConsoleAspect.java} | 14 +-
.../console/core/bean/AlertProbeMsg.java | 4 +-
.../console/core/bean/AlertTemplate.java | 20 +--
.../core/component/FlinkCheckpointProcessor.java | 22 +--
.../ApplicationBuildPipelineController.java | 8 +-
.../core/controller/ApplicationController.java | 28 ++--
.../controller/ApplicationHistoryController.java | 4 +-
.../console/core/controller/MessageController.java | 6 +-
.../console/core/controller/ProjectController.java | 4 +-
.../console/core/entity/AppBuildPipeline.java | 30 ++--
.../console/core/entity/Application.java | 68 ++++----
.../console/core/entity/ApplicationBackUp.java | 4 +-
.../console/core/entity/ApplicationConfig.java | 4 +-
.../streampark/console/core/entity/Effective.java | 6 +-
.../console/core/entity/FlinkCluster.java | 8 +-
.../streampark/console/core/entity/Message.java | 7 +-
.../streampark/console/core/entity/Project.java | 12 +-
.../streampark/console/core/entity/Resource.java | 8 +-
...ssTokenState.java => AccessTokenStateEnum.java} | 4 +-
.../enums/{AlertType.java => AlertTypeEnum.java} | 26 +--
...AppExistsState.java => AppExistsStateEnum.java} | 4 +-
.../enums/{BuildState.java => BuildStateEnum.java} | 6 +-
.../{CandidateType.java => CandidateTypeEnum.java} | 6 +-
...kPointStatus.java => CheckPointStatusEnum.java} | 6 +-
...CheckPointType.java => CheckPointTypeEnum.java} | 6 +-
...ConfigFileType.java => ConfigFileTypeEnum.java} | 6 +-
.../{EffectiveType.java => EffectiveTypeEnum.java} | 4 +-
.../enums/{EngineType.java => EngineTypeEnum.java} | 6 +-
...overStrategy.java => FailoverStrategyEnum.java} | 6 +-
.../{FlinkAppState.java => FlinkAppStateEnum.java} | 46 +++---
...rizedError.java => GitAuthorizedErrorEnum.java} | 8 +-
.../{GitCredential.java => GitCredentialEnum.java} | 8 +-
.../enums/{LoginType.java => LoginTypeEnum.java} | 8 +-
.../enums/{NoticeType.java => NoticeTypeEnum.java} | 6 +-
.../enums/{Operation.java => OperationEnum.java} | 6 +-
.../{OptionState.java => OptionStateEnum.java} | 6 +-
...PermissionType.java => PermissionTypeEnum.java} | 6 +-
...aceholderType.java => PlaceholderTypeEnum.java} | 4 +-
.../{ReleaseState.java => ReleaseStateEnum.java} | 6 +-
.../{ResourceFrom.java => ResourceFromEnum.java} | 6 +-
.../{ResourceType.java => ResourceTypeEnum.java} | 6 +-
.../enums/{StopFrom.java => StopFromEnum.java} | 2 +-
.../enums/{UserType.java => UserTypeEnum.java} | 6 +-
.../console/core/metrics/flink/CheckPoints.java | 16 +-
.../console/core/service/AppBuildPipeService.java | 4 +-
.../console/core/service/EffectiveService.java | 8 +-
.../console/core/service/FlinkClusterService.java | 4 +-
.../console/core/service/FlinkSqlService.java | 6 +-
.../console/core/service/MessageService.java | 4 +-
.../console/core/service/YarnQueueService.java | 4 +-
.../core/service/alert/impl/AlertServiceImpl.java | 12 +-
.../application/ApplicationInfoService.java | 4 +-
.../application/ApplicationManageService.java | 6 +-
.../impl/ApplicationActionServiceImpl.java | 105 ++++++------
.../impl/ApplicationInfoServiceImpl.java | 48 +++---
.../impl/ApplicationManageServiceImpl.java | 92 ++++++-----
.../core/service/impl/AppBuildPipeServiceImpl.java | 60 +++----
.../service/impl/ApplicationBackUpServiceImpl.java | 15 +-
.../service/impl/ApplicationConfigServiceImpl.java | 12 +-
.../core/service/impl/EffectiveServiceImpl.java | 12 +-
.../core/service/impl/ExternalLinkServiceImpl.java | 8 +-
.../core/service/impl/FlinkClusterServiceImpl.java | 45 +++---
.../core/service/impl/FlinkSqlServiceImpl.java | 26 +--
.../core/service/impl/MessageServiceImpl.java | 6 +-
.../core/service/impl/ProjectServiceImpl.java | 26 +--
.../core/service/impl/ResourceServiceImpl.java | 10 +-
.../core/service/impl/SavePointServiceImpl.java | 31 ++--
.../core/service/impl/SqlWorkBenchServiceImpl.java | 20 +--
.../core/service/impl/VariableServiceImpl.java | 4 +-
.../core/service/impl/YarnQueueServiceImpl.java | 14 +-
.../console/core/task/ProjectBuildTask.java | 22 +--
.../console/core/watcher/FlinkAppHttpWatcher.java | 177 +++++++++++----------
.../console/core/watcher/FlinkAppLostWatcher.java | 10 +-
.../console/core/watcher/FlinkClusterWatcher.java | 12 +-
.../core/watcher/FlinkK8sChangeEventListener.java | 32 ++--
.../core/watcher/FlinkK8sWatcherWrapper.java | 24 +--
.../system/controller/AccessTokenController.java | 10 +-
.../system/controller/MemberController.java | 8 +-
.../console/system/controller/SsoController.java | 4 +-
.../console/system/controller/UserController.java | 8 +-
.../streampark/console/system/entity/User.java | 8 +-
.../system/security/impl/AuthenticatorImpl.java | 22 +--
.../system/service/impl/MenuServiceImpl.java | 6 +-
.../system/service/impl/TeamServiceImpl.java | 4 +-
.../system/service/impl/UserServiceImpl.java | 4 +-
.../console/core/task/FlinkK8sObserverBroker.scala | 24 +--
.../core/utils/FlinkK8sDataTypeConverter.scala | 18 +--
.../streampark/console/SpringUnitTestBase.java | 8 +-
.../console/core/entity/ProjectTest.java | 8 +-
.../{AlertTypeTest.java => AlertTypeEnumTest.java} | 8 +-
.../service/ApplicationManageServiceITest.java | 14 +-
.../core/service/ApplicationManageServiceTest.java | 10 +-
.../core/service/FlinkClusterServiceTest.java | 4 +-
.../console/core/service/SavePointServiceTest.java | 20 +--
.../console/core/service/UserServiceTest.java | 20 +--
.../console/core/service/YarnQueueServiceTest.java | 12 +-
.../core/service/alert/AlertServiceTest.java | 4 +-
.../flink/client/bean/CancelRequest.scala | 4 +-
.../flink/client/bean/DeployRequest.scala | 4 +-
.../flink/client/bean/SavepointRequestTrait.scala | 4 +-
.../flink/client/bean/ShutDownRequest.scala | 4 +-
.../flink/client/bean/SubmitRequest.scala | 14 +-
.../client/bean/TriggerSavepointRequest.scala | 4 +-
.../flink/client/FlinkClientEndpoint.scala | 6 +-
.../impl/KubernetesNativeApplicationClient.scala | 12 +-
.../impl/KubernetesNativeSessionClient.scala | 18 ++-
.../flink/client/impl/YarnApplicationClient.scala | 6 +-
.../flink/client/trait/FlinkClientTrait.scala | 18 +--
.../client/trait/KubernetesClientV2Trait.scala | 32 ++--
.../client/trait/KubernetesNativeClientTrait.scala | 4 +-
.../flink/kubernetes/DefaultFlinkK8sWatcher.scala | 8 +-
.../flink/kubernetes/KubernetesRetriever.scala | 4 +-
...FlinkJobState.scala => FlinkJobStateEnum.scala} | 6 +-
...uteMode.scala => FlinkK8sExecuteModeEnum.scala} | 20 +--
.../kubernetes/event/FlinkJobStateEvent.scala | 4 +-
.../flink/kubernetes/model/ClusterKey.scala | 4 +-
.../flink/kubernetes/model/JobStatusCV.scala | 4 +-
.../flink/kubernetes/model/TrackId.scala | 12 +-
.../kubernetes/watcher/FlinkJobStatusWatcher.scala | 52 +++---
...PipelineStatus.java => PipelineStatusEnum.java} | 8 +-
...StepStatus.java => PipelineStepStatusEnum.java} | 8 +-
.../{PipelineType.java => PipelineTypeEnum.java} | 12 +-
.../flink/packer/pipeline/BuildPipeline.scala | 32 ++--
.../flink/packer/pipeline/BuildRequest.scala | 22 +--
.../flink/packer/pipeline/PipeSnapshot.scala | 10 +-
.../impl/FlinkK8sApplicationBuildPipeline.scala | 8 +-
.../impl/FlinkK8sApplicationBuildPipelineV2.scala | 8 +-
.../impl/FlinkK8sSessionBuildPipeline.scala | 2 +-
.../pipeline/impl/FlinkRemoteBuildPipeline.scala | 10 +-
.../impl/FlinkYarnApplicationBuildPipeline.scala | 8 +-
.../flink/core/FlinkStreamingInitializer.scala | 8 +-
.../flink/core/FlinkTableInitializer.scala | 24 +--
...erationStatus.java => OperationStatusEnum.java} | 8 +-
...hOrientation.java => FetchOrientationEnum.java} | 2 +-
.../streampark/gateway/results/OperationInfo.java | 8 +-
.../{ResultKind.java => ResultKindEnum.java} | 2 +-
.../gateway/results/ResultQueryCondition.java | 8 +-
.../streampark/gateway/results/ResultSet.java | 16 +-
.../streampark/gateway/results/TableInfo.java | 17 +-
.../results/{TableKind.java => TableKindEnum.java} | 2 +-
.../gateway/service/SqlGatewayService.java | 4 +-
.../gateway/flink/FlinkSqlGatewayImpl.java | 14 +-
156 files changed, 1119 insertions(+), 1083 deletions(-)
rename
streampark-common/src/main/java/org/apache/streampark/common/enums/{DevelopmentMode.java
=> FlinkDevelopmentMode.java} (80%)
rename
streampark-common/src/main/java/org/apache/streampark/common/enums/{ExecutionMode.java
=> FlinkExecutionMode.java} (78%)
rename
streampark-common/src/main/java/org/apache/streampark/common/enums/{RestoreMode.java
=> FlinkRestoreMode.java} (84%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/aspect/{StreamParkAspect.java
=> ConsoleAspect.java} (95%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{AccessTokenState.java
=> AccessTokenStateEnum.java} (93%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{AlertType.java
=> AlertTypeEnum.java} (79%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{AppExistsState.java
=> AppExistsStateEnum.java} (94%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{BuildState.java
=> BuildStateEnum.java} (92%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{CandidateType.java
=> CandidateTypeEnum.java} (91%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{CheckPointStatus.java
=> CheckPointStatusEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{CheckPointType.java
=> CheckPointTypeEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{ConfigFileType.java
=> ConfigFileTypeEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{EffectiveType.java
=> EffectiveTypeEnum.java} (93%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{EngineType.java
=> EngineTypeEnum.java} (92%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{FailoverStrategy.java
=> FailoverStrategyEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{FlinkAppState.java
=> FlinkAppStateEnum.java} (74%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{GitAuthorizedError.java
=> GitAuthorizedErrorEnum.java} (86%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{GitCredential.java
=> GitCredentialEnum.java} (85%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{LoginType.java
=> LoginTypeEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{NoticeType.java
=> NoticeTypeEnum.java} (91%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{Operation.java
=> OperationEnum.java} (91%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{OptionState.java
=> OptionStateEnum.java} (92%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{PermissionType.java
=> PermissionTypeEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{PlaceholderType.java
=> PlaceholderTypeEnum.java} (93%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{ReleaseState.java
=> ReleaseStateEnum.java} (92%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{ResourceFrom.java
=> ResourceFromEnum.java} (90%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{ResourceType.java
=> ResourceTypeEnum.java} (92%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{StopFrom.java
=> StopFromEnum.java} (97%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/{UserType.java
=> UserTypeEnum.java} (92%)
rename
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/enums/{AlertTypeTest.java
=> AlertTypeEnumTest.java} (80%)
rename
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/enums/{FlinkJobState.scala
=> FlinkJobStateEnum.scala} (90%)
rename
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/enums/{FlinkK8sExecuteMode.scala
=> FlinkK8sExecuteModeEnum.scala} (60%)
rename
streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/{PipelineStatus.java
=> PipelineStatusEnum.java} (90%)
rename
streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/{PipelineStepStatus.java
=> PipelineStepStatusEnum.java} (90%)
rename
streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/{PipelineType.java
=> PipelineTypeEnum.java} (93%)
rename
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/{OperationStatus.java
=> OperationStatusEnum.java} (90%)
rename
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/results/{FetchOrientation.java
=> FetchOrientationEnum.java} (96%)
rename
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/results/{ResultKind.java
=> ResultKindEnum.java} (97%)
rename
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/results/{TableKind.java
=> TableKindEnum.java} (96%)
