This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a change to branch dev-offline-sync
in repository https://gitbox.apache.org/repos/asf/inlong.git
discard 2a08660a07 [INLONG-10360][Manager] Combine schedule state transition
with group operations (#10445)
discard c2f14111f7 [INLONG-10436][Manager] Move schedule configuration from
stream to group (#10437)
discard 0eb6fa750d [INLONG-10396][Manager] Support build-in schedule base on
quartz (#10412)
discard 4d5c873efb [INLONG-10395][Manager] Add interface for schedule client
and engine (#10397)
discard 8bd3a20cb4 [INLONG-10247][Manager] Support schedule information
management for offline sync (#10254)
discard 36afe37602 [INLONG-9862][Manager] Support submit flink job for offline
sync (#9865)
discard fafcece220 [INLONG-9822][Manager] Support flink job runtime execution
mode configuration (#9823)
discard 2674a5645c [INLONG-9813][Manager] Support offline data sync management
(#9814)
discard 051c9716c6 [INLONG-9781][Manager] Add offline sync task type
definition (#9787)
add 466cf626fc [INLONG-10472][Manager] Use audit SDK to obtain audit proxy
URL (#10473)
add bb6cc76a02 [INLONG-10470][Audit] Optimize Audit Proxy configuration
update retry logic (#10471)
add cc9466ff1e [INLONG-10449][Dashboard] The field template for selecting
a new data (#10460)
add 30367cf465 [INLONG-10478][Audit] Default to enable audit for the
Docker and Standalone deployment (#10479)
add 79eba735ed [INLONG-10476][Agent] The audit address should only be
obtained from the manager (#10477)
add e7dd1d05ef [INLONG-10474][Manager] Restrict sortTaskName and
sortConsumeName the same with datanodeName when migrate Inlong Group (#10475)
add fa0858c4c6 [INLONG-10482][Dashboard] Fix the front-end parameters on
the approval page are incorrect (#10483)
add 4ee78b7260 [INLONG-10481][Audit] Optimize Audit domain management
(#10486)
add cee09a6579 [INLONG-10487][Manager] Fix the error of not return success
ListenerResult (#10488)
add b8da024cde [INLONG-10484][Manager] Refactor code in manager-service
module (#10485)
new 565a67ba17 [INLONG-9781][Manager] Add offline sync task type
definition (#9787)
new 0bae684745 [INLONG-9813][Manager] Support offline data sync management
(#9814)
new b83a4831d4 [INLONG-9822][Manager] Support flink job runtime execution
mode configuration (#9823)
new dc8aa2ef5e [INLONG-9862][Manager] Support submit flink job for offline
sync (#9865)
new 2afe763e0d [INLONG-10247][Manager] Support schedule information
management for offline sync (#10254)
new 1b2e6ef5ca [INLONG-10395][Manager] Add interface for schedule client
and engine (#10397)
new a418ea3502 [INLONG-10396][Manager] Support build-in schedule base on
quartz (#10412)
new 151c5f4ea2 [INLONG-10436][Manager] Move schedule configuration from
stream to group (#10437)
new c1bda980b6 [INLONG-10360][Manager] Combine schedule state transition
with group operations (#10445)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2a08660a07)
\
N -- N -- N refs/heads/dev-offline-sync (c1bda980b6)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 9 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:
bin/init-config.sh | 10 +-
bin/inlong-daemon | 2 +-
conf/inlong.conf | 2 -
docker/docker-compose/docker-compose.yml | 5 +-
.../inlong/agent/constant/AgentConstants.java | 3 -
.../inlong/agent/metrics/audit/AuditUtils.java | 33 +-
inlong-agent/agent-docker/Dockerfile | 3 -
inlong-agent/agent-docker/agent-docker.sh | 2 -
.../agent/plugin/store/RocksDBStoreImpl.java | 2 -
.../apache/inlong/audit/entity/AuditComponent.java | 2 +-
.../apache/inlong/audit/utils/ThreadUtils.java} | 20 +-
inlong-audit/audit-docker/Dockerfile | 3 +
inlong-audit/audit-docker/audit-docker.sh | 3 +
.../apache/inlong/audit/heartbeat/Heartbeat.java | 135 ---------
.../org/apache/inlong/audit/node/Application.java | 5 -
.../org/apache/inlong/audit/AuditReporterImpl.java | 4 +-
.../org/apache/inlong/audit/send/ProxyManager.java | 51 +++-
.../apache/inlong/audit/cache/AuditProxyCache.java | 236 ++++-----------
.../inlong/audit/config/OpenApiConstants.java | 7 -
.../inlong/audit/config/ProxyConstants.java} | 27 +-
.../apache/inlong/audit/config/SqlConstants.java | 65 +---
.../org/apache/inlong/audit/entities/ApiType.java | 2 +-
.../inlong/audit/heartbeat/ProxyHeartbeat.java | 96 ------
.../apache/inlong/audit/service/ApiService.java | 25 +-
.../org/apache/inlong/audit/sink/JdbcSink.java | 47 ++-
inlong-audit/conf/audit-service.properties | 8 +-
inlong-audit/sql/apache_inlong_audit_mysql.sql | 54 +---
.../plugins/groups/common/GroupDataTemplateInfo.ts | 1 +
.../plugins/streams/common/StreamDefaultInfo.ts | 34 +--
.../src/ui/components/EditableTable/index.tsx | 37 ++-
.../ui/components/SelectTemplateModal/index.tsx | 147 +++++++++
inlong-dashboard/src/ui/locales/cn.json | 4 +
inlong-dashboard/src/ui/locales/en.json | 4 +
.../src/ui/pages/GroupDataTemplate/CreateModal.tsx | 2 +-
.../GroupDetail/DataStream/StreamItemModal.tsx | 22 --
.../src/ui/pages/Process/Approvals/config.tsx | 3 +-
inlong-dataproxy/dataproxy-docker/Dockerfile | 3 -
.../dataproxy-docker/dataproxy-docker.sh | 3 +-
inlong-manager/manager-docker/Dockerfile | 1 -
inlong-manager/manager-docker/manager-docker.sh | 1 -
.../plugin/listener/StartupSortListener.java | 2 +-
inlong-manager/manager-pojo/pom.xml | 11 +
.../manager/pojo/audit/AuditProxyResponse.java | 12 +-
inlong-manager/manager-service/pom.xml | 11 -
.../service/cluster/InlongClusterService.java | 120 --------
.../service/cluster/InlongClusterServiceImpl.java | 331 ---------------------
.../node/AgentClusterNodeInstallOperator.java | 4 -
.../inlong/manager/service/core/AuditService.java | 2 +-
.../service/core/impl/AuditServiceImpl.java | 2 +-
.../resource/sort/SortFlinkConfigOperator.java | 10 +-
.../manager/service/sink/StreamSinkService.java | 37 ---
.../service/sink/StreamSinkServiceImpl.java | 174 +----------
.../service/source/StreamSourceService.java | 36 ---
.../service/source/StreamSourceServiceImpl.java | 130 +-------
.../service/stream/InlongStreamService.java | 41 ---
.../service/stream/InlongStreamServiceImpl.java | 151 ----------
.../service/tenant/InlongTenantServiceImpl.java | 3 +
.../service/transform/StreamTransformService.java | 38 ---
.../transform/StreamTransformServiceImpl.java | 122 --------
.../manager/web/controller/AuditController.java | 2 +-
.../web/controller/InlongStreamController.java | 2 +-
.../web/controller/StreamSinkController.java | 2 +-
.../web/controller/StreamSourceController.java | 2 +-
.../web/controller/openapi/AuditController.java | 2 +-
.../openapi/OpenInLongClusterController.java | 27 +-
.../openapi/OpenInLongStreamController.java | 8 +-
.../openapi/OpenStreamSinkController.java | 8 +-
.../openapi/OpenStreamSourceController.java | 8 +-
.../openapi/OpenStreamTransformController.java | 9 +-
.../src/main/resources/application-dev.properties | 3 -
.../src/main/resources/application-prod.properties | 3 -
.../src/main/resources/application-test.properties | 3 -
72 files changed, 470 insertions(+), 1960 deletions(-)
copy
inlong-audit/{audit-service/src/main/java/org/apache/inlong/audit/selector/SelectorChangeListenerImpl.java
=> audit-common/src/main/java/org/apache/inlong/audit/utils/ThreadUtils.java}
(70%)
delete mode 100644
inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/heartbeat/Heartbeat.java
copy
inlong-audit/{audit-store/src/main/java/org/apache/inlong/audit/config/StoreConfig.java
=>
audit-service/src/main/java/org/apache/inlong/audit/config/ProxyConstants.java}
(55%)
delete mode 100644
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/heartbeat/ProxyHeartbeat.java
create mode 100644
inlong-dashboard/src/ui/components/SelectTemplateModal/index.tsx
