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/08/30 06:14:56 UTC

[inlong] branch master updated (e5e7e4af8 -> a741f75cf)

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 e5e7e4af8 [INLONG-5733][Sort] Fix hive connector Slf4j class conflict (#5734)
     add a741f75cf [INLONG-5665][SDK] Invoke callback in each MQ message to avoid massive full gc in high load (#5683)

No new revisions were added by this update.

Summary of changes:
 .../inlong/sdk/sort/api/SortClientConfig.java      |  2 +-
 .../fetcher/kafka/KafkaSingleTopicFetcher.java     |  6 +--
 .../fetcher/pulsar/PulsarMultiTopicsFetcher.java   | 12 ++---
 .../fetcher/pulsar/PulsarSingleTopicFetcher.java   |  7 ++-
 .../sort/fetcher/tube/TubeSingleTopicFetcher.java  |  7 ++-
 .../sort/impl/kafka/InLongKafkaFetcherImpl.java    | 12 ++---
 .../sort/impl/pulsar/InLongPulsarFetcherImpl.java  | 57 ++++++----------------
 .../sdk/sort/impl/tube/InLongTubeFetcherImpl.java  |  6 +--
 .../metrics/SortSdkPrometheusMetricListener.java   | 52 +++++++++++---------
 9 files changed, 67 insertions(+), 94 deletions(-)