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

Posted to commits@iceberg.apache.org by st...@apache.org on 2023/03/21 20:11:47 UTC

[iceberg] branch master updated (30daf662b7 -> 26625912d9)

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

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


    from 30daf662b7 Data: Remove AssertHelpers usage (#7134)
     add 26625912d9 Flink: implement clone methods for TableLoader and CatalogLoader to handle Closeable catalog like JDBC properly.

No new revisions were added by this update.

Summary of changes:
 .../org/apache/iceberg/flink/CatalogLoader.java    | 28 ++++++++++++++++++++++
 .../java/org/apache/iceberg/flink/TableLoader.java | 18 +++++++++++++-
 .../apache/iceberg/flink/source/IcebergSource.java |  2 +-
 .../enumerator/ContinuousSplitPlannerImpl.java     | 11 +++++++--
 .../org/apache/iceberg/flink/TestTableLoader.java  |  6 +++++
 .../enumerator/TestContinuousSplitPlannerImpl.java | 26 ++++++++++----------
 6 files changed, 74 insertions(+), 17 deletions(-)