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/02/24 09:24:34 UTC
[incubator-inlong] branch master updated (82f881b -> d9eacd8)

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 82f881b  [INLONG-2586][Manager] Support agent get task from manager (#2674)
     add d9eacd8  [INLONG-2568][DataProxy] Support dynamically getting TubeMq config from Manager #2670

No new revisions were added by this update.

Summary of changes:
 ...oxyPulsarDTO.java => ThirdPartyClusterDTO.java} |  12 +-
 ...ClusterInfo.java => ThirdPartyClusterInfo.java} |   2 +-
 inlong-dataproxy/conf/flume.conf                   |  92 ----
 .../inlong/dataproxy/config/ConfigManager.java     |  63 +--
 .../inlong/dataproxy/config/RemoteConfigJson.java  |   6 +-
 ...der.java => ThirdPartyClusterConfigHolder.java} |  45 +-
 ...sarConfig.java => ThirdPartyClusterConfig.java} | 119 ++++-
 .../org/apache/inlong/dataproxy/sink/MetaSink.java | 549 +++++++++++++--------
 .../apache/inlong/dataproxy/sink/PulsarSink.java   |  77 +--
 .../dataproxy/sink/pulsar/PulsarClientService.java | 102 +++-
 .../config/loader/TestPulsarConfigLoader.java      |  36 --
 .../loader/TestThirdPartyClusterConfigLoader.java  |  73 +++
 .../inlong/dataproxy/sink/TestPulsarSink.java      |  30 +-
 ...g.properties => third_party_cluster.properties} |  12 +-
 .../service/core/DataProxyClusterService.java      |   4 +-
 .../core/impl/DataProxyClusterServiceImpl.java     |  63 ++-
 .../controller/openapi/DataProxyController.java    |   6 +-
 17 files changed, 786 insertions(+), 505 deletions(-)
 rename inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/{ProxyPulsarDTO.java => ThirdPartyClusterDTO.java} (81%)
 copy inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/{PulsarClusterInfo.java => ThirdPartyClusterInfo.java} (97%)
 rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/{PulsarConfigHolder.java => ThirdPartyClusterConfigHolder.java} (53%)
 rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/pojo/{PulsarConfig.java => ThirdPartyClusterConfig.java} (57%)
 delete mode 100644 inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/config/loader/TestPulsarConfigLoader.java
 create mode 100644 inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/config/loader/TestThirdPartyClusterConfigLoader.java
 rename inlong-dataproxy/dataproxy-source/src/test/resources/{pulsar_config.properties => third_party_cluster.properties} (74%)