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(-)
