This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch branch-1.4
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 4634918b5 [INLONG-6484][Sort] Bugfix: fix schema update Circular
dependency error in multiple sink iceberg scenes (#6486)
new b14dbfa7b [INLONG-6044][Manager] Distinguish config processes between
the InlongGroup and InlongStream (#6046)
new 80ae93733 [INLONG-6493][Dashboard] After the Stream is configured
successfully, some parameters cannot be modified (#6494)
new 4e511b880 [INLONG-6502][Manager] Optimize some log and code formats
(#6503)
new d061d9a4e [INLONG-6487][Manager] Add API to force delete the stream
source (#6489)
The 4 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:
.../src/metas/streams/common/StreamDefaultInfo.ts | 35 +++--
.../GroupDetail/DataStream/StreamItemModal.tsx | 14 +-
.../client/api/{NoAuth.java => StreamSource.java} | 16 +--
.../{NoAuthImpl.java => StreamSourceImpl.java} | 28 ++--
.../api/inner/client/StreamSourceClient.java | 17 +++
.../client/api/service/StreamSourceApi.java | 4 +
.../manager/common/consts/InlongConstants.java | 8 ++
.../inlong/manager/common/enums/ClusterStatus.java | 15 +--
.../inlong/manager/common/enums/GroupStatus.java | 8 +-
.../manager/dao/entity/WorkflowProcessEntity.java | 1 +
.../dao/mapper/StreamSourceEntityMapper.java | 3 +
.../dao/mapper/StreamSourceFieldEntityMapper.java | 11 +-
.../resources/mappers/StreamSourceEntityMapper.xml | 17 ++-
.../mappers/StreamSourceFieldEntityMapper.xml | 15 ++-
.../mappers/WorkflowProcessEntityMapper.xml | 27 ++--
.../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/pojo/workflow/ProcessRequest.java | 3 +
.../manager/pojo/workflow/TaskLogRequest.java | 3 +
.../form/process/StreamResourceProcessForm.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/group/InitGroupCompleteListener.java | 24 ++--
.../service/listener/group/InitGroupListener.java | 4 -
.../listener/queue/QueueResourceListener.java | 75 +++++++++++
.../queue/StreamQueueResourceListener.java | 3 -
.../service/listener/sort/SortConfigListener.java | 9 +-
.../stream/InitStreamCompleteListener.java | 7 +-
.../service/operationlog/OperationLogPool.java | 29 +++--
.../queue/kafka/KafkaResourceOperators.java | 44 ++-----
.../resource/queue/pulsar/PulsarOperator.java | 2 +-
.../queue/pulsar/PulsarResourceOperator.java | 143 +++++++++------------
.../resource/sink/es/ElasticsearchConfig.java | 16 +--
.../resource/sink/mysql/MySQLJdbcUtils.java | 88 +++++++------
.../resource/sink/mysql/MySQLResourceOperator.java | 18 +--
.../resource/sort/DefaultSortConfigOperator.java | 21 ++-
.../service/source/AbstractSourceOperator.java | 4 +-
.../service/source/SourceSnapshotOperator.java | 21 +--
.../service/source/StreamSourceService.java | 10 ++
.../service/source/StreamSourceServiceImpl.java | 14 ++
.../source/pulsar/PulsarSourceOperator.java | 1 +
.../service/stream/InlongStreamProcessService.java | 46 +++----
.../service/stream/InlongStreamServiceImpl.java | 5 +-
.../service/workflow/WorkflowServiceImpl.java | 1 +
.../group/CreateGroupWorkflowDefinition.java | 24 +---
.../group/DeleteGroupWorkflowDefinition.java | 8 +-
.../stream/CreateStreamWorkflowDefinition.java | 4 +-
.../stream/DeleteStreamWorkflowDefinition.java | 4 +-
.../inlong/manager/service/RestTemplateConfig.java | 5 +-
.../group/CreateGroupWorkflowDefinitionTest.java | 4 +-
.../resources/application-unit-test.properties | 6 +-
.../main/resources/h2/apache_inlong_manager.sql | 3 +-
.../manager-web/sql/apache_inlong_manager.sql | 3 +-
.../manager/web/auth/openapi/OpenAPIFilter.java | 2 +-
.../manager/web/auth/web/AuthenticationFilter.java | 2 +-
.../manager/web/config/RestTemplateConfig.java | 10 +-
.../web/controller/StreamSourceController.java | 15 ++-
.../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 | 29 +++--
68 files changed, 649 insertions(+), 629 deletions(-)
copy
inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/{NoAuth.java
=> StreamSource.java} (75%)
copy
inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/{NoAuthImpl.java
=> StreamSourceImpl.java} (58%)
delete mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AbstractService.java
