This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch branch-1.7
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 412e56054 [INLONG-7971][Dashboard] Support batch import stream fields
by Excel (#7972)
new 91138d786 [INLONG-8024][Manager] Add extended properties when getting
the status of the sort task info (#8025)
new 58d8e8dba [INLONG-7987][Manager] Add heartbeat timeout status to the
source (#7989)
new 4b99eac73 [INLONG-8026][Agent] Improve the Agent performance (#8027)
The 3 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:
CHANGES.md | 5 +-
.../inlong/agent/message/BatchProxyMessage.java | 1 -
.../inlong/agent/message/PackProxyMessage.java | 54 ++++---
.../org/apache/inlong/agent/core/AgentManager.java | 28 ++--
.../apache/inlong/agent/core/conf/ConfigJetty.java | 17 +--
.../apache/inlong/agent/core/job/JobManager.java | 72 +++++----
.../inlong/agent/core/trigger/TriggerManager.java | 31 ++--
.../agent/plugin/fetcher/ManagerFetcher.java | 168 ++++++++-------------
.../inlong/agent/plugin/sinks/ProxySink.java | 90 +++++++----
.../inlong/agent/plugin/sinks/PulsarSink.java | 3 +-
.../agent/plugin/sources/TextFileSource.java | 16 --
.../sources/reader/file/MonitorTextFile.java | 15 +-
.../org/apache/inlong/agent/plugin/MiniAgent.java | 7 +-
.../agent/plugin/trigger/TestTriggerManager.java | 2 +-
.../manager/common/enums/SimpleSourceStatus.java | 1 +
.../inlong/manager/common/enums/SourceStatus.java | 63 +++++---
.../dao/mapper/InlongClusterNodeEntityMapper.java | 5 +
.../dao/mapper/StreamSourceEntityMapper.java | 22 +++
.../mappers/InlongClusterNodeEntityMapper.xml | 18 ++-
.../resources/mappers/StreamSourceEntityMapper.xml | 59 +++++++-
.../manager/pojo/cluster/BindTagRequest.java | 2 +-
.../manager/pojo/cluster/ClusterTagRequest.java | 2 +-
.../inlong/manager/pojo/sort/SortStatusInfo.java | 3 +
.../inlong/manager/pojo/source/SourceRequest.java | 4 +-
.../service/cluster/InlongClusterServiceImpl.java | 2 +-
.../service/core/impl/AgentServiceImpl.java | 63 +++++++-
.../service/heartbeat/HeartbeatManager.java | 27 +++-
.../service/heartbeat/HeartbeatServiceImpl.java | 2 +
.../source/AbstractSourceOperateListener.java | 6 +-
.../service/source/AbstractSourceOperator.java | 11 +-
.../src/main/resources/application-dev.properties | 5 +
.../src/main/resources/application-prod.properties | 5 +
.../src/main/resources/application-test.properties | 4 +
33 files changed, 520 insertions(+), 293 deletions(-)
