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 337213ac9 [INLONG-6982][Dashboard] Data source and data storage bullet
box title optimization (#6986)
add e6a8d9c7d [INLONG-6657][Sort] Add dirty metric for Kafka (#6750)
No new revisions were added by this update.
Summary of changes:
.../sort/base/metric/sub/SinkSubMetricData.java | 15 ++-
.../sort/base/metric/sub/SinkTopicMetricData.java | 102 ++++++++++++++++
.../inlong/sort/base/util/MetricStateUtils.java | 38 +++++-
.../kafka/DynamicKafkaSerializationSchema.java | 8 ++
.../inlong/sort/kafka/FlinkKafkaProducer.java | 132 +++++++++++++--------
.../apache/inlong/sort/kafka/KafkaDynamicSink.java | 12 +-
.../sort/kafka/table/KafkaDynamicTableFactory.java | 10 +-
.../table/UpsertKafkaDynamicTableFactory.java | 5 +-
8 files changed, 258 insertions(+), 64 deletions(-)
copy
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/loader/CommonPropertiesLoader.java
=>
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/sub/SinkSubMetricData.java
(75%)
create mode 100644
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/sub/SinkTopicMetricData.java
