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 31f2a23f4 [INLONG-6780][Sort] Supports dirty data side-output for JDBC
connector and related sinks (#6752)
add c13113cf8 [INLONG-6907][SortStandalone] Support to close StatsRecorder
of pulsar client (#6911)
No new revisions were added by this update.
Summary of changes:
.../inlong/dataproxy/consts/ConfigConstants.java | 1 +
.../dataproxy/sink/mq/pulsar/PulsarHandler.java | 5 +++
.../impl/pulsarzone/PulsarClusterProducer.java | 39 ++++++++++++----------
.../dataproxy/sink/pulsar/PulsarClientService.java | 25 ++++++++------
.../pulsar/federation/PulsarProducerCluster.java | 3 ++
.../apache/inlong/dataproxy/utils/MockUtils.java | 1 +
.../inlong/sdk/sort/api/ConfigConstants.java | 1 +
.../inlong/sdk/sort/api/SortClientConfig.java | 11 ++++++
.../sdk/sort/impl/InlongTopicManagerImpl.java | 1 +
.../sdk/sort/manager/InlongMultiTopicManager.java | 1 +
.../sdk/sort/manager/InlongSingleTopicManager.java | 1 +
.../sink/pulsar/PulsarProducerCluster.java | 4 +++
12 files changed, 66 insertions(+), 27 deletions(-)
