You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by zi...@apache.org on 2022/11/29 04:55:39 UTC

[inlong] branch master updated (303b6fd63 -> fda87e92a)

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 303b6fd63 [INLONG-6628][Dashboard] The data source supports the Redis type (#6650)
     add fda87e92a [INLONG-6598][Sort] Import small file compact for Apache Iceberg (#6599)

No new revisions were added by this update.

Summary of changes:
 .../apache/inlong/sort/iceberg/FlinkActions.java   | 58 ++++++++++++++++++++++
 .../inlong/sort/iceberg/FlinkConfigOptions.java    | 47 ------------------
 .../sort/iceberg/FlinkDynamicTableFactory.java     | 32 ++++++++++--
 .../inlong/sort/iceberg/IcebergTableSink.java      | 22 +++++---
 .../apache/inlong/sort/iceberg/sink/FlinkSink.java | 17 ++++++-
 .../multiple/IcebergMultipleFilesCommiter.java     |  2 +-
 .../sink/multiple/IcebergSingleFileCommiter.java   | 24 ++++++++-
 7 files changed, 141 insertions(+), 61 deletions(-)
 create mode 100644 inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkActions.java
 delete mode 100644 inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkConfigOptions.java