This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 86a53e1e2 [INLONG-5874][Agent] Use dataTime to report audit metrics
(#5883)
new 632a0261b [INLONG-5969][Sort] Support metrics state restore for hive
connector (#5972)
new 4109c08b7 [INLONG-5970][Sort] Support metrics state restore for
iceberg connector (#5973)
new 9f05ea51e [INLONG-5971][Sort] Support metrics state restore for dlc
connector (#5974)
new 5417acad8 [INLONG-5944][Sort] Add metric state for es6 and es7 (#5968)
new f92c1839d [INLONG-5943][Sort] Add metric state for JDBC (#5966)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../inlong/sort/base/metric/MetricOption.java | 8 +++
.../sort/elasticsearch/ElasticsearchSinkBase.java | 3 +
.../elasticsearch/ElasticsearchSinkFunction.java | 10 +++
.../table/RowElasticsearchSinkFunction.java | 38 ++++++++++
.../hive/filesystem/AbstractStreamingWriter.java | 31 ++++++++
.../iceberg/flink/sink/IcebergStreamWriter.java | 41 +++++++++++
.../sort/iceberg/sink/IcebergStreamWriter.java | 41 +++++++++++
.../jdbc/internal/AbstractJdbcOutputFormat.java | 83 ++++++++++++++++++++++
.../jdbc/internal/GenericJdbcSinkFunction.java | 5 +-
.../jdbc/internal/JdbcBatchingOutputFormat.java | 40 ++++++++++-
10 files changed, 297 insertions(+), 3 deletions(-)
create mode 100644
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/AbstractJdbcOutputFormat.java
