This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch branch-1.5
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 3db90d470 [INLONG-7154][SDK] Fix metric report failure when topic does
not exist (#7158)
new e26610ff1 [INLONG-7156][Agent] Support directly sending raw file data
(#7157)
new fddfceacb [INLONG-7159][Audit] Fix the problem of audit sdk create
thread not deployed (#7160)
new db296b39d [INLONG-7089][Manager] Separate the concept of node tag from
the node table and extract the concept of task group (#7134)
new 34f7f04cb [INLONG-7162][Dashboard] Kafka MQ type details optimization
(#7165)
new b96d4ed4a [INLONG-7161][Sort] Fix bug that Mysql connector only output
the latest record in snapshot stage for table without primary key (#7164)
The 5 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:
.../inlong/agent/constant/AgentConstants.java | 2 +-
.../apache/inlong/agent/core/HeartbeatManager.java | 8 +-
.../sources/reader/file/FileReaderOperator.java | 8 +-
.../apache/inlong/agent/plugin/TestFileAgent.java | 2 +-
.../agent/plugin/sources/TestTextFileReader.java | 34 +++++++-
.../inlong/agent/plugin/task/TestTextFileTask.java | 6 +-
.../agent-plugins/src/test/resources/test/3.txt | 5 ++
inlong-agent/conf/agent.properties | 2 +-
.../inlong/audit/send/ClientPipelineFactory.java | 9 +--
.../apache/inlong/audit/send/SenderChannel.java | 8 +-
.../java/org/apache/inlong/audit/util/Config.java | 13 ++-
.../inlong/common/heartbeat/HeartbeatMsg.java | 4 +-
.../src/components/NodeSelect/index.tsx | 6 +-
.../Agent.ts => consumes/defaults/Kafka.ts} | 6 +-
.../src/metas/consumes/defaults/index.ts | 5 ++
.../src/metas/groups/defaults/Kafka.ts | 1 +
.../src/pages/GroupDetail/Audit/config.tsx | 2 +-
.../inlong/manager/client/api/InlongClient.java | 9 ---
.../manager/client/api/impl/InlongClientImpl.java | 6 --
.../api/inner/client/InlongClusterClient.java | 13 ---
.../client/api/service/InlongClusterApi.java | 4 -
.../manager/common/consts/AgentConstants.java | 8 +-
.../dao/entity/InlongClusterNodeEntity.java | 1 -
.../manager/dao/entity/StreamSourceEntity.java | 2 +-
.../mappers/InlongClusterNodeEntityMapper.xml | 13 ++-
.../resources/mappers/StreamSourceEntityMapper.xml | 14 ++--
.../AgentClusterNodeBindGroupRequest.java} | 19 ++---
.../inlong/manager/pojo/source/SourceRequest.java | 4 +-
.../service/cluster/InlongClusterService.java | 10 ---
.../service/cluster/InlongClusterServiceImpl.java | 55 -------------
.../inlong/manager/service/core/AgentService.java | 8 ++
.../service/core/impl/AgentServiceImpl.java | 92 +++++++++++++++++++---
.../service/heartbeat/HeartbeatManager.java | 24 +++++-
.../service/core/impl/AgentServiceTest.java | 74 ++++++++---------
.../inlong/manager/service/mocks/MockAgent.java | 12 +--
.../main/resources/h2/apache_inlong_manager.sql | 3 +-
.../manager-web/sql/apache_inlong_manager.sql | 3 +-
inlong-manager/manager-web/sql/changes-1.5.0.sql | 6 +-
.../web/controller/InlongClusterController.java | 9 ---
.../web/controller/openapi/AgentController.java | 6 ++
.../sort/cdc/mysql/source/utils/RecordUtils.java | 31 ++++++--
41 files changed, 299 insertions(+), 248 deletions(-)
create mode 100644 inlong-agent/agent-plugins/src/test/resources/test/3.txt
copy inlong-dashboard/src/metas/{clusters/defaults/Agent.ts =>
consumes/defaults/Kafka.ts} (90%)
copy
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/state/StateCallback.java
=>
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/AgentConstants.java
(81%)
mode change 100755 => 100644
rename
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/{ClusterNodeBindTagRequest.java
=> agent/AgentClusterNodeBindGroupRequest.java} (72%)
