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 2022/11/03 15:46:43 UTC
[iceberg] branch master updated (3373a414c1 -> 9e76a846d2)
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 3373a414c1 Build: Add gaborkaszab as a collaborator (#6036)
add b2a95f5625 Flink: Move flink/v1.15 to flink/v1.16
add f3182356f7 Flink: Copy flink/1.15 files from flink/1.16
add 9e76a846d2 Flink: Make flink 1.16 work
No new revisions were added by this update.
Summary of changes:
.github/workflows/flink-ci.yml | 2 +-
.github/workflows/java-ci.yml | 2 +-
.github/workflows/publish-snapshot.yml | 2 +-
dev/stage-binaries.sh | 2 +-
flink/build.gradle | 4 ++
flink/{v1.15 => v1.16}/build.gradle | 4 +-
flink/{v1.14 => v1.16}/flink-runtime/LICENSE | 0
flink/{v1.14 => v1.16}/flink-runtime/NOTICE | 0
.../iceberg/flink/IcebergConnectorSmokeTest.java | 0
.../org/apache/iceberg/flink/CatalogLoader.java | 0
.../org/apache/iceberg/flink/FlinkCatalog.java | 0
.../apache/iceberg/flink/FlinkCatalogFactory.java | 0
.../org/apache/iceberg/flink/FlinkConfParser.java | 0
.../apache/iceberg/flink/FlinkConfigOptions.java | 0
.../iceberg/flink/FlinkDynamicTableFactory.java | 0
.../org/apache/iceberg/flink/FlinkFilters.java | 0
.../org/apache/iceberg/flink/FlinkFixupTypes.java | 0
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 0
.../org/apache/iceberg/flink/FlinkTypeToType.java | 0
.../org/apache/iceberg/flink/FlinkTypeVisitor.java | 0
.../org/apache/iceberg/flink/FlinkWriteConf.java | 0
.../apache/iceberg/flink/FlinkWriteOptions.java | 0
.../org/apache/iceberg/flink/IcebergTableSink.java | 28 +++++++-----
.../org/apache/iceberg/flink/RowDataWrapper.java | 0
.../java/org/apache/iceberg/flink/TableLoader.java | 0
.../org/apache/iceberg/flink/TypeToFlinkType.java | 0
.../org/apache/iceberg/flink/actions/Actions.java | 0
.../flink/actions/RewriteDataFilesAction.java | 0
.../flink/data/AvroWithFlinkSchemaVisitor.java | 0
.../apache/iceberg/flink/data/FlinkAvroReader.java | 0
.../apache/iceberg/flink/data/FlinkAvroWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcReader.java | 0
.../apache/iceberg/flink/data/FlinkOrcReaders.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 0
.../iceberg/flink/data/FlinkParquetReaders.java | 0
.../iceberg/flink/data/FlinkParquetWriters.java | 0
.../iceberg/flink/data/FlinkSchemaVisitor.java | 0
.../iceberg/flink/data/FlinkValueReaders.java | 0
.../iceberg/flink/data/FlinkValueWriters.java | 0
.../flink/data/ParquetWithFlinkSchemaVisitor.java | 0
.../iceberg/flink/data/RowDataProjection.java | 0
.../org/apache/iceberg/flink/data/RowDataUtil.java | 0
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 0
.../apache/iceberg/flink/sink/CommitSummary.java | 0
.../apache/iceberg/flink/sink/DeltaManifests.java | 0
.../flink/sink/DeltaManifestsSerializer.java | 0
.../flink/sink/EqualityFieldKeySelector.java | 0
.../iceberg/flink/sink/FlinkAppenderFactory.java | 0
.../iceberg/flink/sink/FlinkFileWriterFactory.java | 0
.../iceberg/flink/sink/FlinkManifestUtil.java | 0
.../org/apache/iceberg/flink/sink/FlinkSink.java | 0
.../iceberg/flink/sink/IcebergFilesCommitter.java | 0
.../flink/sink/IcebergFilesCommitterMetrics.java | 0
.../iceberg/flink/sink/IcebergStreamWriter.java | 0
.../flink/sink/IcebergStreamWriterMetrics.java | 0
.../flink/sink/ManifestOutputFileFactory.java | 0
.../iceberg/flink/sink/PartitionKeySelector.java | 0
.../iceberg/flink/sink/PartitionedDeltaWriter.java | 0
.../flink/sink/RowDataTaskWriterFactory.java | 0
.../iceberg/flink/sink/TaskWriterFactory.java | 0
.../flink/sink/UnpartitionedDeltaWriter.java | 0
.../apache/iceberg/flink/source/DataIterator.java | 0
.../iceberg/flink/source/FileScanTaskReader.java | 0
.../iceberg/flink/source/FlinkInputFormat.java | 0
.../iceberg/flink/source/FlinkInputSplit.java | 0
.../apache/iceberg/flink/source/FlinkSource.java | 0
.../iceberg/flink/source/FlinkSplitPlanner.java | 0
.../apache/iceberg/flink/source/IcebergSource.java | 0
.../iceberg/flink/source/IcebergTableSource.java | 0
.../flink/source/RowDataFileScanTaskReader.java | 0
.../iceberg/flink/source/RowDataRewriter.java | 0
.../apache/iceberg/flink/source/ScanContext.java | 0
.../apache/iceberg/flink/source/SourceUtil.java | 0
.../flink/source/StreamingMonitorFunction.java | 0
.../flink/source/StreamingReaderOperator.java | 0
.../flink/source/StreamingStartingStrategy.java | 0
.../flink/source/assigner/GetSplitResult.java | 0
.../flink/source/assigner/SimpleSplitAssigner.java | 0
.../assigner/SimpleSplitAssignerFactory.java | 0
.../flink/source/assigner/SplitAssigner.java | 0
.../source/assigner/SplitAssignerFactory.java | 0
.../flink/source/assigner/SplitAssignerType.java | 0
.../enumerator/AbstractIcebergEnumerator.java | 0
.../enumerator/ContinuousEnumerationResult.java | 0
.../enumerator/ContinuousIcebergEnumerator.java | 0
.../source/enumerator/ContinuousSplitPlanner.java | 0
.../enumerator/ContinuousSplitPlannerImpl.java | 0
.../enumerator/IcebergEnumeratorPosition.java | 0
.../IcebergEnumeratorPositionSerializer.java | 0
.../source/enumerator/IcebergEnumeratorState.java | 0
.../IcebergEnumeratorStateSerializer.java | 0
.../source/enumerator/StaticIcebergEnumerator.java | 0
.../flink/source/reader/ArrayBatchRecords.java | 0
.../reader/ArrayPoolDataIteratorBatcher.java | 0
.../flink/source/reader/DataIteratorBatcher.java | 0
.../source/reader/DataIteratorReaderFunction.java | 0
.../flink/source/reader/IcebergSourceReader.java | 0
.../source/reader/IcebergSourceReaderMetrics.java | 0
.../source/reader/IcebergSourceRecordEmitter.java | 0
.../source/reader/IcebergSourceSplitReader.java | 0
.../flink/source/reader/ReaderFunction.java | 0
.../flink/source/reader/RecordAndPosition.java | 0
.../iceberg/flink/source/reader/RecordFactory.java | 0
.../flink/source/reader/RowDataReaderFunction.java | 0
.../flink/source/reader/RowDataRecordFactory.java | 0
.../flink/source/split/IcebergSourceSplit.java | 0
.../source/split/IcebergSourceSplitSerializer.java | 0
.../source/split/IcebergSourceSplitState.java | 0
.../source/split/IcebergSourceSplitStatus.java | 0
.../flink/source/split/SplitRequestEvent.java | 0
.../iceberg/flink/util/FlinkCompatibilityUtil.java | 0
.../org.apache.flink.table.factories.Factory | 0
.../org.apache.flink.table.factories.TableFactory | 0
.../apache/iceberg/flink/FlinkCatalogTestBase.java | 0
.../org/apache/iceberg/flink/FlinkTestBase.java | 0
.../iceberg/flink/HadoopCatalogResource.java | 0
.../apache/iceberg/flink/HadoopTableResource.java | 0
.../apache/iceberg/flink/MiniClusterResource.java | 0
.../org/apache/iceberg/flink/RowDataConverter.java | 0
.../org/apache/iceberg/flink/SimpleDataUtil.java | 0
.../iceberg/flink/TestCatalogTableLoader.java | 0
.../apache/iceberg/flink/TestChangeLogTable.java | 0
.../iceberg/flink/TestDataFileSerialization.java | 0
.../org/apache/iceberg/flink/TestFixtures.java | 0
.../iceberg/flink/TestFlinkCatalogDatabase.java | 0
.../iceberg/flink/TestFlinkCatalogFactory.java | 0
.../iceberg/flink/TestFlinkCatalogTable.java | 0
.../flink/TestFlinkCatalogTablePartitions.java | 0
.../org/apache/iceberg/flink/TestFlinkFilters.java | 0
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 0
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 0
.../apache/iceberg/flink/TestFlinkTableSink.java | 0
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 0
.../java/org/apache/iceberg/flink/TestHelpers.java | 0
.../apache/iceberg/flink/TestIcebergConnector.java | 0
.../flink/TestManifestFileSerialization.java | 0
.../apache/iceberg/flink/TestRowDataWrapper.java | 0
.../org/apache/iceberg/flink/TestTableLoader.java | 0
.../iceberg/flink/TestTableSerialization.java | 0
.../flink/actions/TestRewriteDataFilesAction.java | 0
.../apache/iceberg/flink/data/RandomRowData.java | 0
.../iceberg/flink/data/RowDataToRowMapper.java | 0
.../flink/data/TestFlinkAvroReaderWriter.java | 0
.../flink/data/TestFlinkOrcReaderWriter.java | 0
.../iceberg/flink/data/TestFlinkParquetReader.java | 0
.../iceberg/flink/data/TestFlinkParquetWriter.java | 0
.../iceberg/flink/data/TestRowDataProjection.java | 0
.../iceberg/flink/data/TestRowProjection.java | 0
.../flink/sink/TestCompressionSettings.java | 0
.../iceberg/flink/sink/TestDeltaTaskWriter.java | 0
.../flink/sink/TestFlinkAppenderFactory.java | 0
.../flink/sink/TestFlinkFileWriterFactory.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 0
.../iceberg/flink/sink/TestFlinkManifest.java | 0
.../flink/sink/TestFlinkPartitioningWriters.java | 0
.../flink/sink/TestFlinkPositionDeltaWriters.java | 0
.../flink/sink/TestFlinkRollingFileWriters.java | 0
.../iceberg/flink/sink/TestFlinkWriterMetrics.java | 0
.../flink/sink/TestIcebergFilesCommitter.java | 0
.../flink/sink/TestIcebergStreamWriter.java | 0
.../flink/sink/TestRowDataPartitionKey.java | 0
.../apache/iceberg/flink/sink/TestTaskWriters.java | 0
.../iceberg/flink/source/BoundedTableFactory.java | 0
.../iceberg/flink/source/BoundedTestSource.java | 0
.../flink/source/ChangeLogTableTestBase.java | 0
.../apache/iceberg/flink/source/SplitHelpers.java | 0
.../apache/iceberg/flink/source/SqlHelpers.java | 0
.../flink/source/TestBoundedTableFactory.java | 0
.../iceberg/flink/source/TestFlinkInputFormat.java | 0
.../source/TestFlinkInputFormatReaderDeletes.java | 0
.../flink/source/TestFlinkMergingMetrics.java | 0
.../flink/source/TestFlinkReaderDeletesBase.java | 0
.../apache/iceberg/flink/source/TestFlinkScan.java | 0
.../iceberg/flink/source/TestFlinkScanSql.java | 0
.../iceberg/flink/source/TestFlinkSource.java | 0
.../iceberg/flink/source/TestFlinkSourceSql.java | 0
.../iceberg/flink/source/TestFlinkTableSource.java | 51 ++--------------------
.../flink/source/TestIcebergSourceBounded.java | 0
.../flink/source/TestIcebergSourceBoundedSql.java | 0
.../flink/source/TestIcebergSourceContinuous.java | 0
.../flink/source/TestIcebergSourceFailover.java | 0
.../source/TestIcebergSourceReaderDeletes.java | 0
.../iceberg/flink/source/TestIcebergSourceSql.java | 0
.../flink/source/TestProjectMetaColumn.java | 0
.../iceberg/flink/source/TestSourceUtil.java | 0
.../apache/iceberg/flink/source/TestSqlBase.java | 0
.../iceberg/flink/source/TestStreamScanSql.java | 0
.../flink/source/TestStreamingMonitorFunction.java | 0
.../flink/source/TestStreamingReaderOperator.java | 0
.../source/assigner/TestSimpleSplitAssigner.java | 0
.../enumerator/ManualContinuousSplitPlanner.java | 0
.../TestContinuousIcebergEnumerator.java | 0
.../enumerator/TestContinuousSplitPlannerImpl.java | 0
...estContinuousSplitPlannerImplStartStrategy.java | 0
.../TestIcebergEnumeratorStateSerializer.java | 0
.../source/reader/ReaderFunctionTestBase.java | 0
.../iceberg/flink/source/reader/ReaderUtil.java | 0
.../flink/source/reader/TestArrayBatchRecords.java | 0
.../TestArrayPoolDataIteratorBatcherRowData.java | 0
.../source/reader/TestIcebergSourceReader.java | 0
.../source/reader/TestRowDataReaderFunction.java | 0
.../flink/source/reader/TestingMetricGroup.java | 0
.../split/TestIcebergSourceSplitSerializer.java | 0
.../org.apache.flink.table.factories.Factory | 0
gradle.properties | 4 +-
settings.gradle | 9 ++++
208 files changed, 42 insertions(+), 66 deletions(-)
copy flink/{v1.15 => v1.16}/build.gradle (99%)
copy flink/{v1.14 => v1.16}/flink-runtime/LICENSE (100%)
copy flink/{v1.14 => v1.16}/flink-runtime/NOTICE (100%)
copy flink/{v1.14 => v1.16}/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java (83%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssigner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceRecordEmitter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/FlinkCatalogTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogResource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/HadoopTableResource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/MiniClusterResource.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestDataFileSerialization.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkFilters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkSchemaUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestHelpers.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestManifestFileSerialization.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestRowDataWrapper.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/RandomRowData.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/RowDataToRowMapper.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowDataProjection.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkAppenderFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkFileWriterFactory.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPositionDeltaWriters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkRollingFileWriters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkWriterMetrics.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestRowDataPartitionKey.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTestSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/SplitHelpers.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java (92%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBounded.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceReaderDeletes.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestSimpleSplitAssigner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestIcebergEnumeratorStateSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayBatchRecords.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherRowData.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestingMetricGroup.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/split/TestIcebergSourceSplitSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory (100%)