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/17 07:55:13 UTC
[incubator-inlong] branch master updated (865a301 -> 45aa474)

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 865a301  [INLONG-3179][Manager] Check the source name can not be the same when saving stream source (#3180)
     add 45aa474  [INLONG-3181][DataProxy] Optimizing unit tests and code style (#3182)

No new revisions were added by this update.

Summary of changes:
 .../inlong/dataproxy/config/ConfigHolder.java      | 20 ++---
 .../inlong/dataproxy/config/ConfigManager.java     |  5 --
 .../dataproxy/config/holder/FileConfigHolder.java  | 30 ++++---
 .../config/holder/PropertiesConfigHolder.java      | 51 ++++++------
 .../dataproxy/source/DefaultServiceDecoder.java    | 97 ++++++++--------------
 .../inlong/dataproxy/sink/TestPulsarSink.java      | 29 +------
 .../federation/TestPulsarFederationSink.java       | 20 ++---
 .../federation/TestPulsarProducerFederation.java   | 24 ++----
 .../apache/inlong/dataproxy/utils/MockUtils.java   | 51 ++++--------
 .../{topics.properties => blacklist.properties}    |  2 -
 .../{topics.properties => dc_mapping.properties}   |  2 -
 ...opics.properties => groupid_mapping.properties} |  2 -
 .../resources/{topics.properties => mx.properties} |  2 -
 .../{topics.properties => transfer.properties}     |  2 -
 .../{topics.properties => tube_switch.properties}  |  2 -
 .../{topics.properties => weight.properties}       |  2 -
 .../inlong/sdk/dataproxy/ProxyClientConfig.java    | 54 ++++++------
 .../sdk/dataproxy/threads/MetricWorkerThread.java  | 62 +++++++-------
 .../org/apache/inlong/sdk/dataproxy/AppTest.java   |  8 +-
 .../sdk/dataproxy/TestMetricWorkerThread.java      | 68 ---------------
 .../apache/inlong/sdk/dataproxy/UtilsTest.java}    | 12 ++-
 21 files changed, 193 insertions(+), 352 deletions(-)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => blacklist.properties} (90%)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => dc_mapping.properties} (90%)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => groupid_mapping.properties} (90%)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => mx.properties} (90%)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => transfer.properties} (90%)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => tube_switch.properties} (90%)
 copy inlong-dataproxy/dataproxy-source/src/test/resources/{topics.properties => weight.properties} (90%)
 delete mode 100644 inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk/dataproxy/TestMetricWorkerThread.java
 copy inlong-sdk/dataproxy-sdk/src/{main/java/org/apache/inlong/sdk/dataproxy/MessageSenderFactory.java => test/java/org/apache/inlong/sdk/dataproxy/UtilsTest.java} (77%)