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/incubator-inlong.git.
from 1458d28 [INLONG-2247]Read the consume group offset and store to the
specified topic (#2248)
add 7aef828 [INLONG-2236][Sort] Introduce iceberg sink in
sort-single-tenent (#2239)
No new revisions were added by this update.
Summary of changes:
inlong-sort/pom.xml | 6 +++
.../inlong/sort/protocol/sink/IcebergSinkInfo.java | 46 ++++++++--------------
.../apache/inlong/sort/protocol/sink/SinkInfo.java | 3 +-
inlong-sort/sort-single-tenant/pom.xml | 22 +++++++++++
.../inlong/sort/singletenant/flink/Entrance.java | 16 +++++++-
.../singletenant/flink/utils/CommonUtils.java} | 30 +++++++-------
6 files changed, 76 insertions(+), 47 deletions(-)
copy
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/EncryptInfo.java
=>
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/IcebergSinkInfo.java
(51%)
copy
inlong-sort/{sort-formats/format-csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvValidator.java
=>
sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/utils/CommonUtils.java}
(53%)
