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

Posted to commits@iceberg.apache.org by bl...@apache.org on 2022/07/12 20:24:07 UTC

[iceberg] branch master updated (1afce60cfe -> eeb0af128c)

This is an automated email from the ASF dual-hosted git repository.

blue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


    from 1afce60cfe Python: Bump pre-commit versions (#5203)
     add eeb0af128c Flink: Port #3998 to Flink 1.13 & 1.14 (#5194)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/iceberg/flink/FlinkConfParser.java  |   0
 .../org/apache/iceberg/flink/FlinkWriteConf.java   |   7 --
 .../apache/iceberg/flink/FlinkWriteOptions.java    |   0
 .../org/apache/iceberg/flink/sink/FlinkSink.java   | 106 ++++++++++-----------
 .../flink/sink/RowDataTaskWriterFactory.java       |   4 +-
 .../iceberg/flink/sink/TestFlinkIcebergSink.java   |  51 ++++++++++
 .../flink/sink/TestIcebergStreamWriter.java        |  10 +-
 .../org/apache/iceberg/flink/FlinkConfParser.java  |   0
 .../org/apache/iceberg/flink/FlinkWriteConf.java   |   0
 .../apache/iceberg/flink/FlinkWriteOptions.java    |   0
 .../org/apache/iceberg/flink/sink/FlinkSink.java   |  97 ++++++++-----------
 .../flink/sink/RowDataTaskWriterFactory.java       |   4 +-
 .../iceberg/flink/sink/TestFlinkIcebergSink.java   |  51 ++++++++++
 .../flink/sink/TestIcebergStreamWriter.java        |  10 +-
 14 files changed, 216 insertions(+), 124 deletions(-)
 copy flink/{v1.15 => v1.13}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (100%)
 copy flink/{v1.15 => v1.13}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (93%)
 copy flink/{v1.15 => v1.13}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java (100%)
 copy flink/{v1.15 => v1.14}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (100%)
 copy flink/{v1.15 => v1.14}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (100%)
 copy flink/{v1.15 => v1.14}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java (100%)