This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 699af0d53 [INLONG-7070][Manager][DataProxy] Fix mq configuration
dispatching problem (#7071)
add 6a35533c1 [INLONG-7066][Sort] Kafka connector lost topic level dirty
data metric and state restore for multi sink (#7074)
No new revisions were added by this update.
Summary of changes:
.../sort/base/metric/sub/SinkTableMetricData.java | 25 ++++++-----
.../sort/base/metric/sub/SinkTopicMetricData.java | 48 +++++++++++++++++++---
.../inlong/sort/base/util/MetricStateUtils.java | 1 -
.../kafka/DynamicKafkaSerializationSchema.java | 20 +++++----
.../inlong/sort/kafka/FlinkKafkaProducer.java | 9 ++--
5 files changed, 72 insertions(+), 31 deletions(-)
