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/03/03 08:04:03 UTC

[incubator-inlong] branch master updated (88c550b -> 7277482)

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/incubator-inlong.git.


    from 88c550b  [INLONG-2654][Agent] Report heartbeat to manager (#2778)
     add 7277482  [INLONG-2788][Agent] Support sync send data to dataproxy when needed (#2836)

No new revisions were added by this update.

Summary of changes:
 .../inlong/agent/constant/CommonConstants.java     |  8 +++
 .../apache/inlong/agent/message/ProxyMessage.java  | 19 +++++++
 ...ctorTaskRequestDto.java => DebeziumFormat.java} | 21 ++++++--
 ...askReportDto.java => DebeziumSourceFormat.java} | 10 +++-
 .../apache/inlong/agent/pojo/JobProfileDto.java    |  5 ++
 .../apache/inlong/agent/core/task/TaskWrapper.java |  1 -
 .../agent/plugin/message/PackProxyMessage.java     | 17 ++++++
 .../inlong/agent/plugin/sinks/ProxySink.java       | 18 +++++--
 .../inlong/agent/plugin/sinks/SenderManager.java   | 39 ++++++++++++--
 .../agent/plugin/sources/reader/BinlogReader.java  | 48 ++++++++++++++---
 .../agent/plugin/sources/TestBinlogReader.java     | 60 ++++++++++++++++++++++
 .../inlong/common/pojo/agent/DataConfig.java       |  1 +
 12 files changed, 228 insertions(+), 19 deletions(-)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/{DbCollectorTaskRequestDto.java => DebeziumFormat.java} (73%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/{DbCollectorTaskReportDto.java => DebeziumSourceFormat.java} (88%)
 create mode 100644 inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestBinlogReader.java