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(-)