This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from dbddbbba0 [INLONG-6493][Dashboard] After the Stream is configured
successfully, some parameters cannot be modified (#6494)
add 910b0ad3c [INLONG-6502][Manager] Optimize some log and code formats
(#6503)
No new revisions were added by this update.
Summary of changes:
.../manager/common/consts/InlongConstants.java | 8 ++
.../inlong/manager/common/enums/ClusterStatus.java | 15 +--
.../inlong/manager/common/enums/GroupStatus.java | 8 +-
.../inlong/manager/dao/RestTemplateConfig.java | 5 +-
.../manager/plugin/flink/TaskRunService.java | 50 ++++----
.../plugin/listener/DeleteSortListener.java | 24 ++--
.../plugin/listener/DeleteStreamListener.java | 27 ++---
.../inlong/manager/plugin/util/FlinkUtils.java | 2 +-
.../manager/pojo/sink/mysql/MySQLSinkDTO.java | 13 +-
.../manager/service/core/SortConfigLoader.java | 32 +++--
.../manager/service/core/impl/AbstractService.java | 119 -------------------
.../service/group/InlongGroupProcessService.java | 23 ++--
.../service/heartbeat/HeartbeatManager.java | 2 +-
.../listener/queue/QueueResourceListener.java | 26 ++--
.../service/listener/sort/SortConfigListener.java | 6 +-
.../service/operationlog/OperationLogPool.java | 29 ++---
.../queue/kafka/KafkaResourceOperators.java | 23 ++--
.../resource/queue/pulsar/PulsarOperator.java | 2 +-
.../queue/pulsar/PulsarResourceOperator.java | 131 ++++++++++-----------
.../resource/sink/es/ElasticsearchConfig.java | 16 ++-
.../resource/sink/mysql/MySQLJdbcUtils.java | 88 +++++++-------
.../resource/sink/mysql/MySQLResourceOperator.java | 18 +--
.../resource/sort/DefaultSortConfigOperator.java | 13 +-
.../service/source/AbstractSourceOperator.java | 4 +-
.../service/source/SourceSnapshotOperator.java | 21 ++--
.../source/pulsar/PulsarSourceOperator.java | 1 +
.../service/stream/InlongStreamProcessService.java | 26 ++--
.../service/stream/InlongStreamServiceImpl.java | 5 +-
.../inlong/manager/service/RestTemplateConfig.java | 5 +-
.../resources/application-unit-test.properties | 6 +-
.../manager/web/auth/openapi/OpenAPIFilter.java | 2 +-
.../manager/web/auth/web/AuthenticationFilter.java | 2 +-
.../manager/web/config/RestTemplateConfig.java | 10 +-
.../src/main/resources/application-prod.properties | 3 +-
.../src/main/resources/application-test.properties | 5 +-
.../event/process/ProcessEventListener.java | 13 +-
.../workflow/processor/ServiceTaskProcessor.java | 18 +--
.../workflow/processor/StartEventProcessor.java | 24 ++--
38 files changed, 365 insertions(+), 460 deletions(-)
delete mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AbstractService.java
