This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
from b5df3e01f [INLONG-5746]][Sort] Add spi dictionary of Inlong pb msg
(#5747)
new 6f84779ea [INLONG-5743][Agent] Support function read file data
continuously through the monitoring file (#5744)
new d20a0ae69 [INLONG-5754][Sort] Fix Pulsar connecotr deserialize complex
format with multiple data will cause data loss (#5755)
The 2 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:
.../apache/inlong/agent/constant/JobConstants.java | 16 +++
.../java/org/apache/inlong/agent/pojo/FileJob.java | 22 +++-
.../apache/inlong/agent/pojo/JobProfileDto.java | 8 ++
.../sources/reader/file/FileReaderOperator.java | 8 +-
.../sources/reader/file/MonitorTextFile.java | 131 +++++++++++++++++++++
.../plugin/sources/reader/file/TextFileReader.java | 7 ++
.../src/test/resources/agent.properties | 5 +-
.../sort/pulsar/withoutadmin/PulsarFetcher.java | 6 +-
.../sort/pulsar/withoutadmin/ReaderThread.java | 42 ++++++-
.../inlongmsg/InLongMsgDeserializationSchema.java | 2 +
10 files changed, 235 insertions(+), 12 deletions(-)
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/MonitorTextFile.java
