You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/09/21 02:28:32 UTC
[inlong] branch master updated (56a6147e4 -> bfd2e01e9)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 56a6147e4 [INLONG-5963][Audit] Solve the sdk memory leak problem (#5965)
add bfd2e01e9 [INLONG-5909][Agent] Fix WatchService is no effect in the k8s (#5910)
No new revisions were added by this update.
Summary of changes:
.../apache/inlong/agent/constant/JobConstants.java | 2 +-
.../main/java/org/apache/inlong/agent/db/Db.java | 10 +++
.../org/apache/inlong/agent/db/JobProfileDb.java | 28 ++++++++
.../org/apache/inlong/agent/db/RocksDbImp.java | 17 +++++
.../apache/inlong/agent/pojo/JobProfileDto.java | 1 +
.../org/apache/inlong/agent/core/AgentManager.java | 6 +-
.../java/org/apache/inlong/agent/core/job/Job.java | 25 ++++++-
.../apache/inlong/agent/core/job/JobManager.java | 10 ++-
.../apache/inlong/agent/core/job/JobWrapper.java | 11 +++
.../org/apache/inlong/agent/core/task/Task.java | 4 ++
.../apache/inlong/agent/core/task/TaskManager.java | 4 ++
.../inlong/agent/core/trigger/TriggerManager.java | 83 +++++++++++++++++-----
.../agent/plugin/fetcher/ManagerFetcher.java | 26 +++++++
.../agent/plugin/filter/DateFormatRegex.java | 10 ++-
.../sources/reader/file/FileReaderOperator.java | 3 +
.../sources/reader/file/MonitorTextFile.java | 1 +
.../plugin/sources/reader/file/TextFileReader.java | 12 +++-
.../agent/plugin/trigger/DirectoryTrigger.java | 7 +-
.../inlong/agent/plugin/trigger/PathPattern.java | 1 +
.../inlong/agent/plugin/utils/PluginUtils.java | 7 +-
.../apache/inlong/agent/plugin/TestFileAgent.java | 8 +--
.../agent/plugin/filter/TestDateFormatRegex.java | 39 +++++++---
.../agent/plugin/sources/TestTextFileReader.java | 8 +++
.../src/test/resources/fileAgent.trigger.json | 4 +-
.../src/test/resources/fileAgentJob.json | 4 +-
25 files changed, 279 insertions(+), 52 deletions(-)