private Table lazyTable() {
        if (table == null) {
            tableLoader.open();
            try (TableLoader loader = tableLoader) {
                this.table = loader.loadTable();
            } catch (IOException e) {
                throw new UncheckedIOException("Failed to close table loader", e);
            }
        }

        return table;
    }
Copy from iceberg-flink:iceberg-flink-1.15:1.3.1
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/source/IcebergSource.java