This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/github_actions/zizmorcore/zizmor-action-0.6.4
in repository https://gitbox.apache.org/repos/asf/iceberg.git
discard b73600ffa3 Build: Bump zizmorcore/zizmor-action from 0.6.3 to 0.6.4
add 6c15b3cd7e Build: Bump astral-sh/setup-uv from 10.0.1 to 10.1.0
(#18186)
add b4a178dd16 Build: Bump actions/setup-java from 6.0.0 to 6.0.1 (#18185)
add b10cfd6726 Build: Bump io.netty:netty-buffer from 4.2.17.Final to
4.2.18.Final (#18182)
add 006f11c224 Build: Bump at.yawk.lz4:lz4-java from 1.11.2 to 1.11.3
(#18180)
add b67050b301 Build: Bump org.roaringbitmap:RoaringBitmap from 1.6.21 to
1.6.23 (#18179)
add 7277215aea Build: Bump com.google.cloud:libraries-bom from 26.88.0 to
26.88.1 (#18176)
add 0e0b22f03f Build: Bump jetty from 12.1.12 to 12.1.13 (#18175)
add fe949ab285 Build: Bump datamodel-code-generator from 0.76.2 to 0.80.0
(#18174)
add 96d9880d6f Build: Bump the codeql-action group with 3 updates (#18183)
add 93a4a2a965 Docs: Enhance maintenance documentation with new actions
(#17939)
add e45573b61f Build: Bump nessie from 0.108.4 to 0.108.8 (#18177)
add 566c9ba35c Docs: Fix catalog properties link in terms.md (#18192)
add 4f535ff60e Docs: Rewrite AGENTS.md comment and Javadoc guidance
(#18167)
add cbe9baee54 Docs: Add testing guidance to AGENTS.md (#18166)
add 39a9823b02 Build: exclude site/ from the source release archive
(#18193)
add 8a6830af69 Core, Spark 4.2: Add PositionDeleteIndex.forEachInRange and
use it in vectorized delete checks (#18027)
add 2ffead0eb0 Flink: Backport RowKind fix in DynamicIcebergSink's
DataConverter to 1.20/2.1/2.2 (#18196)
add 781a30f3c9 Build: Bump bouncycastle from 1.85 to 1.86 (#18194)
add ab5d012f91 Parquet: Fix incorrect pruning for nested fields in
optional structs (#18069)
add b5f3639322 Spec: Align the decimal type string with the canonical form
(#18145)
add e8d0f0f300 Core: expose catalog labels on the loaded table via
SupportsLabels (#18046)
add 29ae647f44 Docs: Fix replaceSortOrder example in evolution.md (#18201)
add af4552f698 Build: Bump AWS SDK to 2.54.17 and migrate to Apache
HttpClient 5 (#18195)
add 2df9831946 Docs: Add AI contribution and disclosure rules to AGENTS.md
(#18168)
add 1504ddd5d5 Parquet: Fix Variant conversion in default Avro writer
(#17944)
add 17cf4b4a58 Core: Add inheritance to V4ManifestReader (#18171)
add 7b1934b552 Parquet: Remove commons-lang3 usage from
ParquetVariantReaders (#18208)
add 3deb3e2275 Spark: Fix RewriteManifestsSparkAction sortBy() for dotted
partition field names (#17428)
add ad4e824433 Core: Avoid redundant SplitScanTask wrapper for files that
fit in a single split (#18002)
add 23774790e6 Spark 4.2: Push down opaque partition predicates (#17956)
add 89a6a8776a Spark: Backport forEachInRange vectorized delete checks to
3.5, 4.0 and 4.1 (#18207)
add bb9faedfb2 GCP: Add Caffeine to the gcp-bundle LICENSE (#18218)
add 9409ecf5c7 Build: Add Jackson's Schubfach and fast_double_parser to
runtime LICENSE and NOTICE (#18227)
add 5e7169168d GCP: Add CEL-Java to the gcp-bundle LICENSE (#18226)
add 3957d26daa Core: Implement v4 first row ID assignment (#18225)
add 3316c1d1a4 Core: Do not retry Tasks after interrupt (#18213)
add 212aa894e9 Build: Replace MinIO with RustFS in integration tests
(#18247)
add 729e650b9e Core: Support manifest DVs in V4ManifestReader, remove
includeAll (#18248)
add 26bc8774de Spark 4.1: Fix rewrite failure on tables created with a
sort order (#17814)
add ac16c2950b Core: Reject negative ByteBuffer stream seeks (#17963)
add 1067a1fbf5 Build: Bump docker/setup-buildx-action from 4.3.0 to 4.4.1
(#18282)
add 3249b07783 Build: Bump docker/setup-qemu-action from 4.3.0 to 4.4.0
(#18281)
add b6b98535ef Build: Bump docker/build-push-action from 7.3.0 to 7.4.0
(#18280)
add 2df8cc5099 Build: Bump the codeql-action group with 3 updates (#18279)
add 2b990ba0a8 Build: Bump joda-time:joda-time from 2.14.3 to 2.14.4
(#18278)
add daea862df8 Build: Bump pymarkdownlnt from 0.9.39 to 0.9.40 (#18276)
add 75072c4d6a Build: Bump datamodel-code-generator from 0.80.0 to 0.82.0
(#18275)
add e4bcaa40cb Dell: Validate ECS stream seeks and closed state (#17962)
add 9872c84c9f Flink: Fix DynamicIcebergSink writing NULLs for
case-mismatched columns (#18066)
add 55794516bc Flink: Fix flaky TestFlinkIcebergSinkV2 > testDeleteStats()
(#18241)
add e689699fa6 Flink: Fix dynamic sink HASH distribution check for nested
equality/partition fields (#18296)
add 587f7984ff Arrow: Cover null decimal values with defaults across
batches (#18271)
add 6eb21e9315 Build: Bump software.amazon.awssdk:bom from 2.54.17 to
2.55.1 (#18289)
add 01cf810cd0 Core: Add modified file and row counts to ManifestInfo
(#18212)
add 9719db6d61 Core: V4 refactor metrics config (#18269)
add b60b3c8c46 Spark 4.2: Enable DSv2 cache invalidation test for session
schema change (#18298)
add 7ba28c352c Spec: Forbid writing new equality deletes in v4 (#17783)
add 7d6d369157 Core: Bound Idempotency-Key retries to the advertised key
lifetime (#18070)
add 48330b8dac Flink: Backport case-insensitive DataConverter fix to 1.20,
2.1, and 2.2 (#18295)
add 8bb3713878 Site: Add Iceberg C++ 0.4.0 release blog post (#18273)
add ec8eb2c649 Core: Make content stats schema tests order-independent
(#18302)
add df8ea35dd5 CI: Generalize Markdown path exclusions (#18307)
add e050d4d798 Core: Make MetricsConfig.forTable collect full metrics for
order preserving transform source fields (#17960)
add 505c34e54d Build: Bump jackson versions (#18318)
add 7e3fe2f935 Docs: Require Checkstyle validation in agent instructions
(#18306)
add f5484c4093 Infra: add 1.12.0 to issue template (#18314)
add 0b041b4a48 Flink: Remove v2.3 directory to restore its history
add 8d2e8d3a53 Flink: Move v2.1 to v2.3 directory
add b6456e844c Flink: Add back v2.1 directory
add 9daf2df445 Flink: Re-apply v2.3 changes
add d008ad230b Build: Let revapi compare against 1.12.0 (#18320)
add 106e7428f0 Spec: Rename avg_value_size_in_bytes to total_bytes (#18308)
add 95c7552f57 Flink: Remove support for Flink 2.1 (#18326)
add 82acb6233b Doap: Update DOAP to reference 1.12.0 (#18315)
add f12ec1b5c6 Build: Bump jackson versions (#18333)
add 91c315df8e Core: Make PlanTableScanResponse buider withCredentials
replace instead of append (#17751)
add 85e22de10c Aliyun: Default random port for OSS mock server (#18249)
add 8f825e6e19 Spark: support default values with DDL (#18250)
add ca670d771a Core: Implement unregister table in catalogs and RCKs
(#18203)
add 6a47c21477 Docs: Add release notes for 1.12.0 (#18313)
add 574e44670b Core: Return all metrics field IDs, in schema order (#18331)
add 8102f4cb60 Site: Add Iceberg-Go 0.7.0 release blog post (#18341)
add f051a32bdf Delta: Use POSIX separator for data file paths (#17872)
add dad714b8f0 kafka connect: use a stable coordinator transactional id to
fence stale coordinators (#18039)
add 52ea8a497f API, Core: Add toString to StructProjection and
StructLikeUtil (#18342)
add c81a261852 Core: Project tracked-file partitions onto the resolved
spec (#18108)
add 46f1808f83 Build: Bump zizmorcore/zizmor-action from 0.6.3 to 0.6.4
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b73600ffa3)
\
N -- N -- N
refs/heads/dependabot/github_actions/zizmorcore/zizmor-action-0.6.4 (46f1808f83)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitattributes | 2 +
.github/ISSUE_TEMPLATE/iceberg_bug_report.yml | 3 +-
.../trivyignore/kafka-connect-runtime.trivyignore | 9 +
.github/workflows/api-binary-compatibility.yml | 2 +-
.github/workflows/codeql.yml | 4 +-
.github/workflows/cve-scan.yml | 20 +-
.github/workflows/delta-conversion-ci.yml | 7 +-
.github/workflows/flink-ci.yml | 7 +-
.github/workflows/hive-ci.yml | 5 +-
.github/workflows/java-ci.yml | 11 +-
.github/workflows/jmh-benchmarks.yml | 2 +-
.github/workflows/kafka-connect-ci.yml | 5 +-
.github/workflows/open-api.yml | 2 +-
.../publish-iceberg-rest-fixture-docker.yml | 8 +-
.github/workflows/publish-snapshot.yml | 2 +-
.github/workflows/recurring-jmh-benchmarks.yml | 2 +-
.github/workflows/source-release-ci.yml | 2 +-
.github/workflows/spark-ci.yml | 5 +-
AGENTS.md | 72 +-
.../iceberg/aliyun/oss/mock/AliyunOSSMock.java | 6 +-
.../aliyun/oss/mock/AliyunOSSMockExtension.java | 13 +-
.../java/org/apache/iceberg/catalog/Catalog.java | 15 +
.../org/apache/iceberg/catalog/SessionCatalog.java | 15 +
.../org/apache/iceberg/util/StructProjection.java | 23 +
.../apache/iceberg/util/TestStructProjection.java | 29 +
.../vectorized/TestVectorizedDefaultValues.java | 32 +-
aws-bundle/LICENSE | 76 +-
aws-bundle/NOTICE | 14 +-
aws-bundle/build.gradle | 2 +-
aws-bundle/runtime-deps.txt | 93 +-
.../s3/{MinioUtil.java => ObjectStoreUtil.java} | 59 +-
...TestMinioUtil.java => TestObjectStoreUtil.java} | 9 +-
.../org/apache/iceberg/aws/s3/TestS3FileIO.java | 14 +-
.../aws/s3/TestS3FileIOWithLegacyMinIO.java | 37 -
.../apache/iceberg/aws/s3/TestS3InputStream.java | 8 +-
.../apache/iceberg/aws/s3/TestS3OutputStream.java | 8 +-
.../iceberg/aws/s3/signer/TestS3RestSigner.java | 25 +-
.../aws/ApacheHttpClientConfigurations.java | 10 +-
.../org/apache/iceberg/aws/AwsClientFactories.java | 4 +-
.../apache/iceberg/aws/HttpClientProperties.java | 66 +-
.../iceberg/aws/TestHttpClientConfigurations.java | 14 +-
.../iceberg/aws/TestHttpClientProperties.java | 8 +-
.../iceberg/aws/s3/TestS3FileIOLegacyMd5.java | 114 ++
azure-bundle/LICENSE | 62 +
azure-bundle/NOTICE | 14 +-
build.gradle | 5 +-
.../deletes/PositionDeleteIndexBenchmark.java | 126 ++
.../org/apache/iceberg/BaseContentScanTask.java | 2 +
.../main/java/org/apache/iceberg/BaseTable.java | 21 +-
.../java/org/apache/iceberg/CachingCatalog.java | 7 +
.../main/java/org/apache/iceberg/ManifestInfo.java | 18 +-
.../org/apache/iceberg/ManifestInfoStruct.java | 79 +-
.../java/org/apache/iceberg/MetricsConfig.java | 167 +-
.../main/java/org/apache/iceberg/MetricsUtil.java | 14 +-
.../main/java/org/apache/iceberg/SchemaOrder.java | 123 ++
.../java/org/apache/iceberg/SupportsLabels.java | 16 +-
.../main/java/org/apache/iceberg/TrackedFile.java | 4 +-
.../java/org/apache/iceberg/TrackedFileStruct.java | 40 +-
.../java/org/apache/iceberg/TrackingStruct.java | 92 +-
.../java/org/apache/iceberg/V4ManifestReader.java | 166 +-
.../main/java/org/apache/iceberg/avro/Avro.java | 6 +
.../org/apache/iceberg/avro/InternalReader.java | 11 +-
.../apache/iceberg/catalog/BaseSessionCatalog.java | 5 +
.../iceberg/deletes/BitmapPositionDeleteIndex.java | 5 +
.../iceberg/deletes/EmptyPositionDeleteIndex.java | 12 +
.../iceberg/deletes/PositionDeleteIndex.java | 24 +
.../iceberg/deletes/RoaringPositionBitmap.java | 79 +
.../apache/iceberg/inmemory/InMemoryCatalog.java | 24 +
.../apache/iceberg/io/MultiBufferInputStream.java | 2 +
.../apache/iceberg/io/SingleBufferInputStream.java | 2 +
.../java/org/apache/iceberg/jdbc/JdbcCatalog.java | 38 +
.../java/org/apache/iceberg/jdbc/JdbcUtil.java | 4 +
.../org/apache/iceberg/rest/CatalogHandlers.java | 16 +
.../java/org/apache/iceberg/rest/Endpoint.java | 2 +
.../rest/ExponentialHttpRequestRetryStrategy.java | 130 +-
.../java/org/apache/iceberg/rest/HTTPClient.java | 32 +-
.../java/org/apache/iceberg/rest/RESTCatalog.java | 5 +
.../org/apache/iceberg/rest/RESTSerializers.java | 27 +
.../apache/iceberg/rest/RESTSessionCatalog.java | 80 +-
.../java/org/apache/iceberg/rest/RESTTable.java | 6 +-
.../org/apache/iceberg/rest/ResourcePaths.java | 13 +
.../responses/FetchPlanningResultResponse.java | 9 +-
.../rest/responses/PlanTableScanResponse.java | 9 +-
...wResponse.java => UnregisterTableResponse.java} | 25 +-
.../responses/UnregisterTableResponseParser.java | 78 +
.../org/apache/iceberg/util/SerializableMap.java | 8 +-
.../org/apache/iceberg/util/StructLikeUtil.java | 7 +
.../main/java/org/apache/iceberg/util/Tasks.java | 28 +
.../java/org/apache/iceberg/MetricsTestUtil.java} | 32 +-
.../org/apache/iceberg/TestFileGenerationUtil.java | 9 +-
.../org/apache/iceberg/TestLabelsOnBaseTable.java | 70 +
.../org/apache/iceberg/TestManifestInfoStruct.java | 137 +-
.../test/java/org/apache/iceberg/TestMetrics.java | 24 +-
.../java/org/apache/iceberg/TestMetricsConfig.java | 329 +++-
.../java/org/apache/iceberg/TestMetricsModes.java | 229 +--
.../java/org/apache/iceberg/TestSchemaOrder.java | 121 ++
.../java/org/apache/iceberg/TestStatsUtil.java | 8 +-
.../apache/iceberg/TestTrackedFileAdapters.java | 23 +-
.../org/apache/iceberg/TestTrackedFileStruct.java | 156 +-
.../org/apache/iceberg/TestTrackingStruct.java | 172 +-
.../org/apache/iceberg/TestV4ManifestReader.java | 649 ++++++-
.../java/org/apache/iceberg/V4TestComparators.java | 6 +-
.../org/apache/iceberg/catalog/CatalogTests.java | 45 +
.../deletes/TestBitmapPositionDeleteIndex.java | 190 ++
.../iceberg/deletes/TestRoaringPositionBitmap.java | 132 ++
.../iceberg/inmemory/TestInMemoryCatalog.java | 5 +
.../iceberg/io/TestByteBufferInputStreams.java | 26 +
.../org/apache/iceberg/jdbc/TestJdbcCatalog.java | 5 +
.../apache/iceberg/mumbling/MumblingTestUtil.java | 10 +-
.../apache/iceberg/rest/RESTCatalogAdapter.java | 10 +
.../test/java/org/apache/iceberg/rest/Route.java | 6 +
.../TestExponentialHttpRequestRetryStrategy.java | 182 ++
.../org/apache/iceberg/rest/TestHTTPClient.java | 20 +
.../apache/iceberg/rest/TestRESTCatalogLabels.java | 137 ++
.../TestFetchPlanningResultResponseParser.java | 38 +
.../responses/TestPlanTableScanResponseParser.java | 37 +
.../TestUnregisterTableResponseParser.java | 92 +
.../org/apache/iceberg/util/TestTableScanUtil.java | 140 +-
.../java/org/apache/iceberg/util/TestTasks.java | 140 ++
.../iceberg/dell/ecs/EcsSeekableInputStream.java | 6 +
.../dell/ecs/TestEcsSeekableInputStream.java | 51 +
.../delta/BaseSnapshotDeltaLakeTableAction.java | 3 +-
dev/stage-binaries.sh | 2 +-
doap.rdf | 6 +-
docker/iceberg-flink-quickstart/docker-compose.yml | 45 +-
docker/iceberg-flink-quickstart/test.sql | 2 +-
docs/docs/aws.md | 22 +-
docs/docs/evolution.md | 2 +-
docs/docs/maintenance.md | 114 ++
docs/docs/spark-procedures.md | 8 +-
flink/build.gradle | 4 -
flink/v1.20/flink-runtime/LICENSE | 62 +
flink/v1.20/flink-runtime/NOTICE | 14 +-
.../iceberg/flink/sink/dynamic/DataConverter.java | 60 +-
.../flink/sink/dynamic/HashKeyGenerator.java | 15 +-
.../flink/sink/dynamic/TableMetadataCache.java | 4 +-
.../iceberg/flink/sink/dynamic/TableUpdater.java | 4 +-
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 8 +-
.../iceberg/flink/sink/TestIcebergSinkV2.java | 7 +-
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 60 +
.../flink/sink/dynamic/TestHashKeyGenerator.java | 100 +
.../flink/sink/dynamic/TestRowDataConverter.java | 18 +-
flink/v2.1/build.gradle | 267 ---
flink/v2.1/flink-runtime/LICENSE | 1047 -----------
flink/v2.1/flink-runtime/NOTICE | 439 -----
flink/v2.1/flink-runtime/runtime-deps.txt | 31 -
.../iceberg/flink/TestIcebergConnectorSmoke.java | 21 -
...namicRecordSerializerDeserializerBenchmark.java | 139 --
.../sink/shuffle/MapRangePartitionerBenchmark.java | 121 --
.../shuffle/SketchRangePartitionerBenchmark.java | 114 --
.../StatisticsRecordSerializerBenchmark.java | 127 --
.../runtime/types/FlinkScalaKryoInstantiator.java | 26 -
.../types/variant/BinaryVariantAccessorUtils.java | 86 -
.../org/apache/iceberg/flink/CatalogLoader.java | 215 ---
.../org/apache/iceberg/flink/FlinkCatalog.java | 1088 -----------
.../apache/iceberg/flink/FlinkCatalogFactory.java | 215 ---
.../org/apache/iceberg/flink/FlinkConfParser.java | 297 ---
.../apache/iceberg/flink/FlinkConfigOptions.java | 113 --
.../iceberg/flink/FlinkCreateTableOptions.java | 119 --
.../iceberg/flink/FlinkDynamicTableFactory.java | 277 ---
.../iceberg/flink/FlinkEnvironmentContext.java | 31 -
.../org/apache/iceberg/flink/FlinkFilters.java | 266 ---
.../org/apache/iceberg/flink/FlinkFixupTypes.java | 50 -
.../org/apache/iceberg/flink/FlinkReadConf.java | 213 ---
.../org/apache/iceberg/flink/FlinkReadOptions.java | 118 --
.../org/apache/iceberg/flink/FlinkRowData.java | 47 -
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 380 ----
.../apache/iceberg/flink/FlinkSourceFilter.java | 49 -
.../org/apache/iceberg/flink/FlinkTypeToType.java | 215 ---
.../org/apache/iceberg/flink/FlinkTypeVisitor.java | 80 -
.../org/apache/iceberg/flink/FlinkWriteConf.java | 292 ---
.../apache/iceberg/flink/FlinkWriteOptions.java | 120 --
.../org/apache/iceberg/flink/IcebergTableSink.java | 306 ----
.../org/apache/iceberg/flink/RowDataWrapper.java | 162 --
.../java/org/apache/iceberg/flink/TableLoader.java | 159 --
.../org/apache/iceberg/flink/TypeToFlinkType.java | 152 --
.../org/apache/iceberg/flink/actions/Actions.java | 52 -
.../flink/actions/RewriteDataFilesAction.java | 76 -
.../flink/data/AvroWithFlinkSchemaVisitor.java | 81 -
.../apache/iceberg/flink/data/FlinkAvroWriter.java | 179 --
.../iceberg/flink/data/FlinkFormatModels.java | 64 -
.../apache/iceberg/flink/data/FlinkOrcReader.java | 138 --
.../apache/iceberg/flink/data/FlinkOrcReaders.java | 290 ---
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 172 --
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 368 ----
.../iceberg/flink/data/FlinkParquetReaders.java | 881 ---------
.../iceberg/flink/data/FlinkParquetWriters.java | 696 -------
.../iceberg/flink/data/FlinkPlannedAvroReader.java | 202 ---
.../iceberg/flink/data/FlinkSchemaVisitor.java | 163 --
.../iceberg/flink/data/FlinkValueReaders.java | 387 ----
.../iceberg/flink/data/FlinkValueWriters.java | 314 ----
.../flink/data/FlinkVariantShreddingAnalyzer.java | 72 -
.../flink/data/ParquetWithFlinkSchemaVisitor.java | 242 ---
.../iceberg/flink/data/RowDataProjection.java | 356 ----
.../org/apache/iceberg/flink/data/RowDataUtil.java | 111 --
.../apache/iceberg/flink/data/StructRowData.java | 344 ----
.../iceberg/flink/data/VariantRowDataWrapper.java | 322 ----
.../formats/avro/AvroToRowDataConverters.java | 303 ----
.../iceberg/flink/formats/avro/JodaConverter.java | 69 -
.../formats/avro/RowDataToAvroConverters.java | 394 ----
.../avro/typeutils/AvroSchemaConverter.java | 625 -------
.../maintenance/api/ConvertEqualityDeletes.java | 303 ----
.../api/ConvertEqualityDeletesConfig.java | 90 -
.../flink/maintenance/api/DeleteOrphanFiles.java | 339 ----
.../maintenance/api/DeleteOrphanFilesConfig.java | 216 ---
.../flink/maintenance/api/ExpireSnapshots.java | 164 --
.../maintenance/api/ExpireSnapshotsConfig.java | 151 --
.../maintenance/api/FlinkMaintenanceConfig.java | 138 --
.../flink/maintenance/api/JdbcLockFactory.java | 318 ----
.../iceberg/flink/maintenance/api/LockConfig.java | 260 ---
.../maintenance/api/MaintenanceTaskBuilder.java | 233 ---
.../flink/maintenance/api/RewriteDataFiles.java | 333 ----
.../maintenance/api/RewriteDataFilesConfig.java | 176 --
.../flink/maintenance/api/TableMaintenance.java | 443 -----
.../iceberg/flink/maintenance/api/TaskResult.java | 64 -
.../iceberg/flink/maintenance/api/Trigger.java | 65 -
.../flink/maintenance/api/TriggerLockFactory.java | 64 -
.../flink/maintenance/api/ZKRetryPolicies.java | 36 -
.../flink/maintenance/api/ZkLockFactory.java | 271 ---
.../maintenance/operator/BaseCoordinator.java | 306 ----
.../flink/maintenance/operator/DVPosition.java | 54 -
.../flink/maintenance/operator/DVWriteResult.java | 46 -
.../operator/DataFileRewriteCommitter.java | 210 ---
.../operator/DataFileRewritePlanner.java | 232 ---
.../operator/DataFileRewriteRunner.java | 271 ---
.../maintenance/operator/DeleteFilesProcessor.java | 121 --
.../operator/EqualityConvertCommitter.java | 392 ----
.../operator/EqualityConvertDVWriter.java | 354 ----
.../operator/EqualityConvertPKIndex.java | 297 ---
.../maintenance/operator/EqualityConvertPlan.java | 81 -
.../operator/EqualityConvertPlanner.java | 842 ---------
.../operator/EqualityConvertReader.java | 254 ---
.../operator/EqualityDeleteFileScanTask.java | 51 -
.../operator/ExpireSnapshotsProcessor.java | 136 --
.../flink/maintenance/operator/FileNameReader.java | 49 -
.../maintenance/operator/FileUriKeySelector.java | 60 -
.../operator/FlinkAddedRowsScanTask.java | 72 -
.../flink/maintenance/operator/IndexCommand.java | 108 --
.../maintenance/operator/ListFileSystemFiles.java | 133 --
.../maintenance/operator/ListMetadataFiles.java | 94 -
.../maintenance/operator/LockFactoryBuilder.java | 89 -
.../maintenance/operator/LockRegisterEvent.java | 47 -
.../maintenance/operator/LockReleaseEvent.java | 56 -
.../flink/maintenance/operator/LockRemover.java | 146 --
.../operator/LockRemoverCoordinator.java | 60 -
.../maintenance/operator/LockRemoverOperator.java | 115 --
.../operator/LockRemoverOperatorFactory.java | 86 -
.../flink/maintenance/operator/LogUtil.java | 26 -
.../maintenance/operator/MetadataTablePlanner.java | 133 --
.../flink/maintenance/operator/MonitorSource.java | 206 ---
.../maintenance/operator/OrphanFilesDetector.java | 191 --
.../flink/maintenance/operator/ReadCommand.java | 86 -
.../operator/SerializedEqualityValues.java | 51 -
.../operator/SingleThreadedIteratorSource.java | 197 --
.../flink/maintenance/operator/SkipOnError.java | 90 -
.../maintenance/operator/StructLikeSerializer.java | 139 --
.../flink/maintenance/operator/TableChange.java | 249 ---
.../operator/TableMaintenanceMetrics.java | 78 -
.../flink/maintenance/operator/TableReader.java | 120 --
.../maintenance/operator/TaskResultAggregator.java | 104 --
.../maintenance/operator/TriggerEvaluator.java | 151 --
.../flink/maintenance/operator/TriggerManager.java | 308 ----
.../operator/TriggerManagerCoordinator.java | 59 -
.../operator/TriggerManagerOperator.java | 322 ----
.../operator/TriggerManagerOperatorFactory.java | 110 --
.../flink/maintenance/operator/TriggerUtil.java | 46 -
.../sink/AvroGenericRecordToRowDataMapper.java | 61 -
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 128 --
.../flink/sink/BucketPartitionKeySelector.java | 70 -
.../iceberg/flink/sink/BucketPartitioner.java | 103 --
.../iceberg/flink/sink/BucketPartitionerUtil.java | 125 --
.../iceberg/flink/sink/CachingTableSupplier.java | 91 -
.../apache/iceberg/flink/sink/CommitSummary.java | 108 --
.../sink/CommittableToTableChangeConverter.java | 107 --
.../apache/iceberg/flink/sink/DeltaManifests.java | 73 -
.../flink/sink/DeltaManifestsSerializer.java | 124 --
.../flink/sink/EqualityFieldKeySelector.java | 88 -
.../iceberg/flink/sink/FlinkFileWriterFactory.java | 191 --
.../iceberg/flink/sink/FlinkManifestUtil.java | 188 --
.../org/apache/iceberg/flink/sink/FlinkSink.java | 786 --------
.../iceberg/flink/sink/FlinkWriteResult.java | 40 -
.../iceberg/flink/sink/IcebergCommittable.java | 95 -
.../flink/sink/IcebergCommittableSerializer.java | 68 -
.../iceberg/flink/sink/IcebergCommitter.java | 337 ----
.../iceberg/flink/sink/IcebergFilesCommitter.java | 490 -----
.../flink/sink/IcebergFilesCommitterFactory.java | 72 -
.../flink/sink/IcebergFilesCommitterMetrics.java | 75 -
.../org/apache/iceberg/flink/sink/IcebergSink.java | 1161 ------------
.../iceberg/flink/sink/IcebergSinkBuilder.java | 103 --
.../iceberg/flink/sink/IcebergSinkWriter.java | 113 --
.../iceberg/flink/sink/IcebergStreamWriter.java | 119 --
.../flink/sink/IcebergStreamWriterMetrics.java | 161 --
.../iceberg/flink/sink/IcebergWriteAggregator.java | 155 --
.../flink/sink/ManifestOutputFileFactory.java | 103 --
.../iceberg/flink/sink/PartitionKeySelector.java | 66 -
.../iceberg/flink/sink/PartitionedDeltaWriter.java | 100 -
.../flink/sink/RowDataTaskWriterFactory.java | 277 ---
.../org/apache/iceberg/flink/sink/SinkUtil.java | 156 --
.../iceberg/flink/sink/TaskWriterFactory.java | 45 -
.../flink/sink/UnpartitionedDeltaWriter.java | 72 -
.../iceberg/flink/sink/WriteResultSerializer.java | 63 -
.../flink/sink/dynamic/CompareSchemasVisitor.java | 299 ---
.../iceberg/flink/sink/dynamic/DataConverter.java | 235 ---
.../flink/sink/dynamic/DynamicCommittable.java | 100 -
.../sink/dynamic/DynamicCommittableSerializer.java | 106 --
.../flink/sink/dynamic/DynamicCommitter.java | 427 -----
.../sink/dynamic/DynamicCommitterMetrics.java | 50 -
.../flink/sink/dynamic/DynamicIcebergSink.java | 604 -------
.../iceberg/flink/sink/dynamic/DynamicRecord.java | 168 --
.../flink/sink/dynamic/DynamicRecordGenerator.java | 34 -
.../flink/sink/dynamic/DynamicRecordInternal.java | 166 --
.../dynamic/DynamicRecordInternalSerializer.java | 370 ----
.../sink/dynamic/DynamicRecordInternalType.java | 96 -
.../flink/sink/dynamic/DynamicRecordProcessor.java | 240 ---
.../sink/dynamic/DynamicRecordWithConfig.java | 94 -
.../flink/sink/dynamic/DynamicSinkUtil.java | 87 -
.../sink/dynamic/DynamicTableRecordGenerator.java | 102 --
.../sink/dynamic/DynamicTableUpdateOperator.java | 99 -
.../flink/sink/dynamic/DynamicWriteResult.java | 55 -
.../sink/dynamic/DynamicWriteResultAggregator.java | 245 ---
.../sink/dynamic/DynamicWriteResultSerializer.java | 64 -
.../iceberg/flink/sink/dynamic/DynamicWriter.java | 223 ---
.../flink/sink/dynamic/DynamicWriterMetrics.java | 74 -
.../flink/sink/dynamic/EvolveSchemaVisitor.java | 243 ---
.../flink/sink/dynamic/FlinkDynamicSinkConf.java | 120 --
.../sink/dynamic/FlinkDynamicSinkOptions.java | 91 -
.../flink/sink/dynamic/HashKeyGenerator.java | 409 -----
.../iceberg/flink/sink/dynamic/JobOperatorKey.java | 57 -
.../iceberg/flink/sink/dynamic/LRUCache.java | 64 -
.../flink/sink/dynamic/PartitionSpecEvolution.java | 137 --
.../iceberg/flink/sink/dynamic/TableCreator.java | 34 -
.../iceberg/flink/sink/dynamic/TableKey.java | 79 -
.../flink/sink/dynamic/TableMetadataCache.java | 323 ----
.../flink/sink/dynamic/TableSerializerCache.java | 141 --
.../iceberg/flink/sink/dynamic/TableUpdater.java | 226 ---
.../VariantAvroDynamicTableRecordGenerator.java | 223 ---
.../iceberg/flink/sink/dynamic/WriteTarget.java | 132 --
.../sink/shuffle/AggregatedStatisticsTracker.java | 264 ---
.../flink/sink/shuffle/CompletedStatistics.java | 128 --
.../shuffle/CompletedStatisticsSerializer.java | 188 --
.../iceberg/flink/sink/shuffle/DataStatistics.java | 48 -
.../sink/shuffle/DataStatisticsCoordinator.java | 536 ------
.../shuffle/DataStatisticsCoordinatorProvider.java | 70 -
.../flink/sink/shuffle/DataStatisticsOperator.java | 277 ---
.../shuffle/DataStatisticsOperatorFactory.java | 96 -
.../sink/shuffle/DataStatisticsSerializer.java | 204 ---
.../flink/sink/shuffle/GlobalStatistics.java | 114 --
.../sink/shuffle/GlobalStatisticsSerializer.java | 199 --
.../iceberg/flink/sink/shuffle/KeyAssignment.java | 155 --
.../iceberg/flink/sink/shuffle/MapAssignment.java | 242 ---
.../flink/sink/shuffle/MapDataStatistics.java | 88 -
.../flink/sink/shuffle/MapRangePartitioner.java | 95 -
.../flink/sink/shuffle/RangePartitioner.java | 110 --
.../sink/shuffle/RequestGlobalStatisticsEvent.java | 40 -
.../flink/sink/shuffle/SketchDataStatistics.java | 87 -
.../flink/sink/shuffle/SketchRangePartitioner.java | 51 -
.../iceberg/flink/sink/shuffle/SketchUtil.java | 161 --
.../flink/sink/shuffle/SortKeySerializer.java | 408 -----
.../sink/shuffle/SortKeySketchSerializer.java | 143 --
.../iceberg/flink/sink/shuffle/SortKeyUtil.java | 58 -
.../flink/sink/shuffle/StatisticsEvent.java | 76 -
.../flink/sink/shuffle/StatisticsOrRecord.java | 132 --
.../sink/shuffle/StatisticsOrRecordSerializer.java | 208 ---
.../shuffle/StatisticsOrRecordTypeInformation.java | 109 --
.../iceberg/flink/sink/shuffle/StatisticsType.java | 55 -
.../iceberg/flink/sink/shuffle/StatisticsUtil.java | 143 --
.../AvroGenericRecordFileScanTaskReader.java | 42 -
.../apache/iceberg/flink/source/DataIterator.java | 158 --
.../iceberg/flink/source/DataTaskReader.java | 47 -
.../iceberg/flink/source/FileScanTaskReader.java | 35 -
.../iceberg/flink/source/FlinkInputFormat.java | 141 --
.../iceberg/flink/source/FlinkInputSplit.java | 48 -
.../apache/iceberg/flink/source/FlinkSource.java | 318 ----
.../iceberg/flink/source/FlinkSplitPlanner.java | 189 --
.../apache/iceberg/flink/source/IcebergSource.java | 705 --------
.../iceberg/flink/source/IcebergTableSource.java | 240 ---
.../flink/source/RowDataFileScanTaskReader.java | 162 --
.../iceberg/flink/source/RowDataRewriter.java | 166 --
.../RowDataToAvroGenericRecordConverter.java | 70 -
.../apache/iceberg/flink/source/ScanContext.java | 601 ------
.../apache/iceberg/flink/source/SourceUtil.java | 77 -
.../flink/source/StreamingMonitorFunction.java | 270 ---
.../flink/source/StreamingReaderOperator.java | 250 ---
.../flink/source/StreamingStartingStrategy.java | 61 -
.../source/assigner/DefaultSplitAssigner.java | 119 --
.../flink/source/assigner/GetSplitResult.java | 77 -
.../assigner/OrderedSplitAssignerFactory.java | 46 -
.../assigner/SimpleSplitAssignerFactory.java | 37 -
.../flink/source/assigner/SplitAssigner.java | 124 --
.../source/assigner/SplitAssignerFactory.java | 30 -
.../flink/source/assigner/SplitAssignerType.java | 33 -
.../enumerator/AbstractIcebergEnumerator.java | 188 --
.../enumerator/ContinuousEnumerationResult.java | 57 -
.../enumerator/ContinuousIcebergEnumerator.java | 188 --
.../source/enumerator/ContinuousSplitPlanner.java | 30 -
.../enumerator/ContinuousSplitPlannerImpl.java | 248 ---
.../source/enumerator/EnumerationHistory.java | 100 -
.../enumerator/IcebergEnumeratorPosition.java | 79 -
.../IcebergEnumeratorPositionSerializer.java | 90 -
.../source/enumerator/IcebergEnumeratorState.java | 65 -
.../IcebergEnumeratorStateSerializer.java | 194 --
.../source/enumerator/StaticIcebergEnumerator.java | 51 -
.../flink/source/reader/ArrayBatchRecords.java | 179 --
.../reader/ArrayPoolDataIteratorBatcher.java | 161 --
.../source/reader/AvroGenericRecordConverter.java | 69 -
.../reader/AvroGenericRecordReaderFunction.java | 110 --
.../reader/ColumnStatsWatermarkExtractor.java | 111 --
.../source/reader/ConverterReaderFunction.java | 117 --
.../flink/source/reader/DataIteratorBatcher.java | 36 -
.../source/reader/DataIteratorReaderFunction.java | 43 -
.../flink/source/reader/IcebergSourceReader.java | 77 -
.../source/reader/IcebergSourceReaderMetrics.java | 61 -
.../source/reader/IcebergSourceSplitReader.java | 178 --
.../flink/source/reader/LimitableDataIterator.java | 56 -
.../flink/source/reader/ListBatchRecords.java | 85 -
.../source/reader/ListDataIteratorBatcher.java | 94 -
.../source/reader/MetaDataReaderFunction.java | 65 -
.../flink/source/reader/PoolWithWakeup.java | 108 --
.../flink/source/reader/ReaderFunction.java | 31 -
.../flink/source/reader/RecordAndPosition.java | 79 -
.../iceberg/flink/source/reader/RecordFactory.java | 34 -
.../iceberg/flink/source/reader/RecordLimiter.java | 45 -
.../iceberg/flink/source/reader/RowConverter.java | 64 -
.../flink/source/reader/RowDataConverter.java | 32 -
.../flink/source/reader/RowDataReaderFunction.java | 115 --
.../flink/source/reader/RowDataRecordFactory.java | 74 -
.../source/reader/SerializableRecordEmitter.java | 40 -
.../source/reader/SplitWatermarkExtractor.java | 28 -
.../flink/source/reader/WakeableIterator.java | 35 -
.../reader/WatermarkExtractorRecordEmitter.java | 70 -
.../flink/source/split/IcebergSourceSplit.java | 221 ---
.../source/split/IcebergSourceSplitSerializer.java | 64 -
.../source/split/IcebergSourceSplitState.java | 37 -
.../source/split/IcebergSourceSplitStatus.java | 25 -
.../flink/source/split/SerializableComparator.java | 24 -
.../flink/source/split/SplitComparators.java | 78 -
.../flink/source/split/SplitRequestEvent.java | 54 -
.../iceberg/flink/util/ElapsedTimeGauge.java | 47 -
.../iceberg/flink/util/FlinkAlterTableUtil.java | 260 ---
.../iceberg/flink/util/FlinkCompatibilityUtil.java | 56 -
.../apache/iceberg/flink/util/FlinkPackage.java | 61 -
.../iceberg/flink/util/SerializerHelper.java | 209 ---
.../org.apache.flink.table.factories.Factory | 17 -
.../flink/AvroGenericRecordConverterBase.java | 90 -
.../org/apache/iceberg/flink/CatalogTestBase.java | 180 --
.../org/apache/iceberg/flink/DataGenerator.java | 45 -
.../org/apache/iceberg/flink/DataGenerators.java | 1575 ----------------
.../iceberg/flink/HadoopCatalogExtension.java | 105 --
.../apache/iceberg/flink/HadoopTableExtension.java | 59 -
.../iceberg/flink/MiniFlinkClusterExtension.java | 67 -
.../org/apache/iceberg/flink/RowDataConverter.java | 160 --
.../org/apache/iceberg/flink/SimpleDataUtil.java | 484 -----
.../java/org/apache/iceberg/flink/SqlBase.java | 110 --
.../java/org/apache/iceberg/flink/TestBase.java | 145 --
.../apache/iceberg/flink/TestCatalogLoader.java | 116 --
.../iceberg/flink/TestCatalogTableLoader.java | 113 --
.../apache/iceberg/flink/TestChangeLogTable.java | 296 ---
.../iceberg/flink/TestDataFileSerialization.java | 205 ---
.../org/apache/iceberg/flink/TestFixtures.java | 61 -
.../iceberg/flink/TestFlinkAnonymousTable.java | 65 -
.../iceberg/flink/TestFlinkCatalogDatabase.java | 253 ---
.../iceberg/flink/TestFlinkCatalogFactory.java | 119 --
.../iceberg/flink/TestFlinkCatalogTable.java | 788 --------
.../flink/TestFlinkCatalogTablePartitions.java | 119 --
.../apache/iceberg/flink/TestFlinkCatalogView.java | 581 ------
.../TestFlinkCatalogViewIncapableCatalog.java | 116 --
.../apache/iceberg/flink/TestFlinkConfParser.java | 61 -
.../org/apache/iceberg/flink/TestFlinkFilters.java | 467 -----
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 101 --
.../flink/TestFlinkRESTCatalogDatabase.java | 60 -
.../apache/iceberg/flink/TestFlinkReadConf.java | 116 --
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 474 -----
.../apache/iceberg/flink/TestFlinkTableSink.java | 325 ----
.../flink/TestFlinkTableSinkCompaction.java | 214 ---
.../iceberg/flink/TestFlinkTableSinkExtended.java | 401 ----
.../apache/iceberg/flink/TestFlinkUnknownType.java | 179 --
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 341 ----
.../apache/iceberg/flink/TestFlinkUuidType.java | 192 --
.../flink/TestFlinkVariantShreddingType.java | 985 ----------
.../apache/iceberg/flink/TestFlinkVariantType.java | 128 --
.../java/org/apache/iceberg/flink/TestHelpers.java | 758 --------
.../apache/iceberg/flink/TestIcebergConnector.java | 549 ------
.../flink/TestManifestFileSerialization.java | 173 --
.../apache/iceberg/flink/TestRowDataWrapper.java | 94 -
.../org/apache/iceberg/flink/TestTableLoader.java | 57 -
.../iceberg/flink/TestTableSerialization.java | 110 --
.../flink/actions/TestRewriteDataFilesAction.java | 528 ------
.../apache/iceberg/flink/data/RandomRowData.java | 38 -
.../iceberg/flink/data/RowDataToRowMapper.java | 50 -
.../flink/data/TestFlinkAvroReaderWriter.java | 141 --
.../iceberg/flink/data/TestFlinkFormatModel.java | 86 -
.../flink/data/TestFlinkOrcReaderWriter.java | 123 --
.../iceberg/flink/data/TestFlinkParquetReader.java | 284 ---
.../iceberg/flink/data/TestFlinkParquetWriter.java | 128 --
.../iceberg/flink/data/TestFlinkVariants.java | 183 --
.../iceberg/flink/data/TestRowDataProjection.java | 621 -------
.../iceberg/flink/data/TestRowProjection.java | 582 ------
.../iceberg/flink/data/TestStructRowData.java | 125 --
.../flink/data/TestVariantRowDataWrapper.java | 292 ---
.../api/MaintenanceTaskInfraExtension.java | 78 -
.../maintenance/api/MaintenanceTaskTestBase.java | 120 --
.../api/TestConvertEqualityDeletes.java | 1529 ----------------
.../api/TestConvertEqualityDeletesConfig.java | 69 -
.../api/TestConvertEqualityDeletesE2E.java | 196 --
.../maintenance/api/TestDeleteOrphanFiles.java | 340 ----
.../api/TestDeleteOrphanFilesConfig.java | 91 -
.../flink/maintenance/api/TestExpireSnapshots.java | 233 ---
.../maintenance/api/TestExpireSnapshotsConfig.java | 93 -
.../flink/maintenance/api/TestJdbcLockFactory.java | 106 --
.../flink/maintenance/api/TestLockFactoryBase.java | 93 -
.../flink/maintenance/api/TestMaintenanceE2E.java | 152 --
.../maintenance/api/TestRewriteDataFiles.java | 695 -------
.../api/TestRewriteDataFilesConfig.java | 142 --
.../maintenance/api/TestTableMaintenance.java | 512 ------
.../api/TestTableMaintenanceCoordinationLock.java | 344 ----
.../flink/maintenance/api/TestZkLockFactory.java | 128 --
.../flink/maintenance/operator/CollectingSink.java | 116 --
.../maintenance/operator/CoordinatorTestBase.java | 43 -
.../flink/maintenance/operator/ManualSource.java | 319 ----
.../operator/MetricsReporterFactoryForTests.java | 192 --
.../maintenance/operator/OperatorTestBase.java | 545 ------
.../flink/maintenance/operator/RewriteUtil.java | 94 -
.../operator/TestDataFileRewriteCommitter.java | 281 ---
.../operator/TestDataFileRewritePlanner.java | 301 ----
.../operator/TestDataFileRewriteRunner.java | 379 ----
.../operator/TestDeleteFilesProcessor.java | 115 --
.../operator/TestEqualityConvertCommitter.java | 678 -------
.../operator/TestEqualityConvertDVWriter.java | 485 -----
.../operator/TestEqualityConvertPKIndex.java | 747 --------
.../operator/TestEqualityConvertPlanner.java | 1209 -------------
.../operator/TestEqualityConvertReader.java | 421 -----
.../operator/TestExpireSnapshotsProcessor.java | 122 --
.../maintenance/operator/TestFlinkPojoTypes.java | 47 -
.../operator/TestListFileSystemFiles.java | 110 --
.../operator/TestListMetadataFiles.java | 125 --
.../flink/maintenance/operator/TestLockConfig.java | 84 -
.../operator/TestLockFactoryBuilder.java | 109 --
.../operator/TestLockRemoveCoordinator.java | 69 -
.../maintenance/operator/TestLockRemover.java | 444 -----
.../operator/TestLockRemoverOperation.java | 228 ---
.../maintenance/operator/TestMonitorSource.java | 360 ----
.../operator/TestOrphanFilesDetector.java | 246 ---
.../maintenance/operator/TestSkipOnError.java | 100 -
.../operator/TestStructLikeSerializer.java | 164 --
.../operator/TestTablePlanerAndReader.java | 120 --
.../operator/TestTaskResultAggregator.java | 78 -
.../maintenance/operator/TestTriggerManager.java | 671 -------
.../operator/TestTriggerManagerCoordinator.java | 102 --
.../operator/TestTriggerManagerOperator.java | 668 -------
.../apache/iceberg/flink/sink/SinkTestUtil.java | 62 -
.../sink/TestAvroGenericRecordToRowDataMapper.java | 38 -
.../flink/sink/TestBucketPartitionKeySelector.java | 67 -
.../iceberg/flink/sink/TestBucketPartitioner.java | 108 --
.../TestBucketPartitionerFlinkIcebergSink.java | 233 ---
.../flink/sink/TestBucketPartitionerUtil.java | 126 --
.../flink/sink/TestCachingTableSupplier.java | 81 -
.../TestCommittableToTableChangeConverter.java | 324 ----
.../flink/sink/TestCompressionSettings.java | 260 ---
.../iceberg/flink/sink/TestDeltaTaskWriter.java | 434 -----
.../flink/sink/TestFlinkFileWriterFactory.java | 65 -
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 143 --
.../flink/sink/TestFlinkIcebergSinkBase.java | 133 --
.../flink/sink/TestFlinkIcebergSinkBranch.java | 158 --
.../sink/TestFlinkIcebergSinkDistributionMode.java | 658 -------
.../flink/sink/TestFlinkIcebergSinkExtended.java | 250 ---
...FlinkIcebergSinkRangeDistributionBucketing.java | 268 ---
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 256 ---
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 424 -----
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 151 --
.../TestFlinkIcebergSinkV2DistributionMode.java | 707 --------
.../iceberg/flink/sink/TestFlinkManifest.java | 315 ----
.../flink/sink/TestFlinkPartitioningWriters.java | 76 -
.../flink/sink/TestFlinkPositionDeltaWriters.java | 65 -
.../flink/sink/TestFlinkRollingFileWriters.java | 50 -
.../iceberg/flink/sink/TestFlinkWriterMetrics.java | 67 -
.../iceberg/flink/sink/TestIcebergCommitter.java | 1487 ---------------
.../flink/sink/TestIcebergFilesCommitter.java | 1225 -------------
.../apache/iceberg/flink/sink/TestIcebergSink.java | 563 ------
.../iceberg/flink/sink/TestIcebergSinkBranch.java | 142 --
.../sink/TestIcebergSinkTableMaintenance.java | 459 -----
.../iceberg/flink/sink/TestIcebergSinkV2.java | 289 ---
.../flink/sink/TestIcebergSinkV2Branch.java | 110 --
.../flink/sink/TestIcebergStreamWriter.java | 409 -----
.../flink/sink/TestIcebergStreamWriterMetrics.java | 42 -
.../flink/sink/TestManifestOutputFileFactory.java | 112 --
.../flink/sink/TestRowDataPartitionKey.java | 298 ---
.../apache/iceberg/flink/sink/TestTaskWriters.java | 241 ---
.../DynamicRecordInternalSerializerTestBase.java | 100 -
.../sink/dynamic/TestCompareSchemasVisitor.java | 386 ----
.../dynamic/TestDynamicCommittableSerializer.java | 114 --
.../flink/sink/dynamic/TestDynamicCommitter.java | 1164 ------------
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 1905 --------------------
.../sink/dynamic/TestDynamicIcebergSinkPerf.java | 244 ---
.../TestDynamicRecordInternalSerializer.java | 119 --
...DynamicRecordInternalSerializerWriteSchema.java | 28 -
...namicRecordInternalSerializerWriteSchemaId.java | 28 -
...cordInternalSerializerWriteSchemaIdLongUTF.java | 28 -
...RecordInternalSerializerWriteSchemaLongUTF.java | 28 -
.../sink/dynamic/TestDynamicRecordProcessor.java | 101 --
.../sink/dynamic/TestDynamicRecordWithConfig.java | 120 --
.../dynamic/TestDynamicTableUpdateOperator.java | 244 ---
.../dynamic/TestDynamicWriteResultAggregator.java | 259 ---
.../dynamic/TestDynamicWriteResultSerializer.java | 78 -
.../flink/sink/dynamic/TestDynamicWriter.java | 378 ----
.../sink/dynamic/TestEvolveSchemaVisitor.java | 834 ---------
.../flink/sink/dynamic/TestHashKeyGenerator.java | 715 --------
.../iceberg/flink/sink/dynamic/TestLRUCache.java | 88 -
.../sink/dynamic/TestPartitionSpecEvolution.java | 188 --
.../flink/sink/dynamic/TestRowDataConverter.java | 294 ---
.../flink/sink/dynamic/TestTableMetadataCache.java | 220 ---
.../sink/dynamic/TestTableSerializerCache.java | 167 --
.../flink/sink/dynamic/TestTableUpdater.java | 434 -----
...TestVariantAvroDynamicTableRecordGenerator.java | 502 ------
.../flink/sink/shuffle/DataDistributionUtil.java | 178 --
.../iceberg/flink/sink/shuffle/Fixtures.java | 101 --
.../shuffle/TestAggregatedStatisticsTracker.java | 465 -----
.../shuffle/TestCompletedStatisticsSerializer.java | 103 --
.../sink/shuffle/TestDataDistributionUtil.java | 49 -
.../shuffle/TestDataStatisticsCoordinator.java | 373 ----
.../TestDataStatisticsCoordinatorProvider.java | 187 --
.../sink/shuffle/TestDataStatisticsOperator.java | 380 ----
.../sink/shuffle/TestDataStatisticsSerializer.java | 53 -
.../shuffle/TestGlobalStatisticsSerializer.java | 59 -
.../flink/sink/shuffle/TestMapDataStatistics.java | 67 -
.../sink/shuffle/TestMapRangePartitioner.java | 436 -----
.../flink/sink/shuffle/TestRangePartitioner.java | 65 -
.../sink/shuffle/TestRangePartitionerSkew.java | 183 --
.../sink/shuffle/TestSketchDataStatistics.java | 60 -
.../sink/shuffle/TestSketchRangePartitioner.java | 88 -
.../iceberg/flink/sink/shuffle/TestSketchUtil.java | 200 --
.../sink/shuffle/TestSortKeySerializerBase.java | 65 -
.../shuffle/TestSortKeySerializerNestedStruct.java | 55 -
.../shuffle/TestSortKeySerializerPrimitives.java | 93 -
.../shuffle/TestSortKeySerializerSnapshot.java | 235 ---
.../flink/sink/shuffle/TestSortKeyUtil.java | 73 -
.../shuffle/TestStatisticsOrRecordSerializer.java | 72 -
.../TestStatisticsOrRecordTypeInformation.java | 46 -
.../iceberg/flink/source/BoundedTableFactory.java | 184 --
.../iceberg/flink/source/BoundedTestSource.java | 108 --
.../flink/source/ChangeLogTableTestBase.java | 95 -
.../apache/iceberg/flink/source/SplitHelpers.java | 200 --
.../apache/iceberg/flink/source/SqlHelpers.java | 60 -
.../iceberg/flink/source/TableSourceTestBase.java | 105 --
.../flink/source/TestBoundedTableFactory.java | 81 -
.../iceberg/flink/source/TestFlinkInputFormat.java | 211 ---
.../source/TestFlinkInputFormatReaderDeletes.java | 71 -
.../flink/source/TestFlinkMergingMetrics.java | 67 -
.../flink/source/TestFlinkMetaDataTable.java | 814 ---------
.../flink/source/TestFlinkReaderDeletesBase.java | 90 -
.../apache/iceberg/flink/source/TestFlinkScan.java | 540 ------
.../iceberg/flink/source/TestFlinkScanSql.java | 69 -
.../iceberg/flink/source/TestFlinkSource.java | 90 -
.../flink/source/TestFlinkSourceConfig.java | 61 -
.../iceberg/flink/source/TestFlinkSourceSql.java | 87 -
.../iceberg/flink/source/TestFlinkTableSource.java | 561 ------
.../flink/source/TestIcebergSourceBounded.java | 151 --
.../TestIcebergSourceBoundedConverterBase.java | 223 ---
.../TestIcebergSourceBoundedGenericRecord.java | 96 -
.../flink/source/TestIcebergSourceBoundedRow.java | 58 -
.../flink/source/TestIcebergSourceBoundedSql.java | 76 -
.../flink/source/TestIcebergSourceContinuous.java | 573 ------
.../flink/source/TestIcebergSourceFailover.java | 397 ----
...cebergSourceFailoverWithWatermarkExtractor.java | 130 --
.../source/TestIcebergSourceInferParallelism.java | 181 --
.../source/TestIcebergSourceReaderDeletes.java | 102 --
.../iceberg/flink/source/TestIcebergSourceSql.java | 242 ---
.../TestIcebergSourceWithWatermarkExtractor.java | 470 -----
.../TestIcebergSpeculativeExecutionSupport.java | 206 ---
.../source/TestMetadataTableReadableMetrics.java | 364 ----
.../flink/source/TestProjectMetaColumn.java | 189 --
.../TestRowDataToAvroGenericRecordConverter.java | 36 -
.../iceberg/flink/source/TestScanContext.java | 113 --
.../iceberg/flink/source/TestSourceUtil.java | 61 -
.../apache/iceberg/flink/source/TestSqlBase.java | 173 --
.../iceberg/flink/source/TestStreamScanSql.java | 490 -----
.../flink/source/TestStreamingMonitorFunction.java | 399 ----
.../flink/source/TestStreamingReaderOperator.java | 288 ---
.../source/assigner/SplitAssignerTestBase.java | 132 --
.../source/assigner/TestDefaultSplitAssigner.java | 43 -
.../TestFileSequenceNumberBasedSplitAssigner.java | 81 -
.../assigner/TestWatermarkBasedSplitAssigner.java | 143 --
.../enumerator/ManualContinuousSplitPlanner.java | 97 -
.../TestContinuousIcebergEnumerator.java | 352 ----
.../enumerator/TestContinuousSplitPlannerImpl.java | 734 --------
...estContinuousSplitPlannerImplStartStrategy.java | 219 ---
.../source/enumerator/TestEnumerationHistory.java | 135 --
.../TestIcebergEnumeratorStateSerializer.java | 146 --
.../source/reader/ReaderFunctionTestBase.java | 214 ---
.../iceberg/flink/source/reader/ReaderUtil.java | 139 --
.../flink/source/reader/TestArrayBatchRecords.java | 69 -
.../TestArrayPoolDataIteratorBatcherRowData.java | 541 ------
.../TestArrayPoolDataIteratorBatcherWakeup.java | 175 --
.../reader/TestColumnStatsWatermarkExtractor.java | 198 --
.../source/reader/TestIcebergSourceReader.java | 177 --
.../source/reader/TestLimitableDataIterator.java | 82 -
.../flink/source/reader/TestPoolWithWakeup.java | 122 --
.../source/reader/TestRowDataReaderFunction.java | 69 -
.../TestWatermarkExtractorRecordEmitter.java | 164 --
.../flink/source/reader/TestingMetricGroup.java | 102 --
.../split/TestIcebergSourceSplitSerializer.java | 183 --
.../iceberg/flink/util/TestFlinkPackage.java | 55 -
...he.flink.metrics.reporter.MetricReporterFactory | 16 -
.../org.apache.flink.table.factories.Factory | 16 -
flink/v2.2/flink-runtime/LICENSE | 62 +
flink/v2.2/flink-runtime/NOTICE | 14 +-
.../iceberg/flink/sink/dynamic/DataConverter.java | 60 +-
.../flink/sink/dynamic/HashKeyGenerator.java | 15 +-
.../flink/sink/dynamic/TableMetadataCache.java | 4 +-
.../iceberg/flink/sink/dynamic/TableUpdater.java | 4 +-
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 8 +-
.../iceberg/flink/sink/TestIcebergSinkV2.java | 7 +-
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 60 +
.../flink/sink/dynamic/TestHashKeyGenerator.java | 100 +
.../flink/sink/dynamic/TestRowDataConverter.java | 18 +-
flink/v2.3/flink-runtime/LICENSE | 62 +
flink/v2.3/flink-runtime/NOTICE | 14 +-
.../iceberg/flink/sink/dynamic/DataConverter.java | 58 +-
.../flink/sink/dynamic/HashKeyGenerator.java | 15 +-
.../flink/sink/dynamic/TableMetadataCache.java | 4 +-
.../iceberg/flink/sink/dynamic/TableUpdater.java | 4 +-
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 8 +-
.../iceberg/flink/sink/TestIcebergSinkV2.java | 7 +-
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 60 +
.../flink/sink/dynamic/TestHashKeyGenerator.java | 100 +
.../flink/sink/dynamic/TestRowDataConverter.java | 9 +-
format/spec.md | 27 +-
gcp-bundle/LICENSE | 81 +-
gcp-bundle/NOTICE | 14 +-
gradle.properties | 2 +-
gradle/libs.versions.toml | 37 +-
jmh.gradle | 4 -
kafka-connect/build.gradle | 1 +
.../docker/docker-compose.yml | 42 +-
.../kafka-connect-runtime/runtime-deps.txt | 82 +-
.../org/apache/iceberg/connect/TestContext.java | 26 +-
.../iceberg/connect/TestCoordinatorFencing.java | 164 ++
.../apache/iceberg/connect/IcebergSinkConfig.java | 15 +-
.../apache/iceberg/connect/channel/Channel.java | 45 +-
.../iceberg/connect/channel/CommitterImpl.java | 10 +-
.../iceberg/connect/channel/Coordinator.java | 7 +-
.../iceberg/connect/channel/CoordinatorThread.java | 18 +
.../connect/channel/NotRunningException.java | 4 +
.../org/apache/iceberg/connect/channel/Worker.java | 2 +-
.../iceberg/connect/channel/ChannelTestBase.java | 13 +
.../iceberg/connect/channel/TestChannel.java | 3 +-
.../iceberg/connect/channel/TestCommitterImpl.java | 40 +-
.../iceberg/connect/channel/TestCoordinator.java | 111 +-
open-api/requirements.txt | 2 +-
.../rest/RESTCompatibilityKitCatalogTests.java | 59 +
.../java/org/apache/iceberg/orc/OrcMetrics.java | 3 +-
.../java/org/apache/iceberg/InternalParquet.java | 3 +-
.../iceberg/data/parquet/InternalReader.java | 13 +-
.../org/apache/iceberg/parquet/ParquetAvro.java | 4 +
.../org/apache/iceberg/parquet/ParquetMetrics.java | 16 +-
.../iceberg/parquet/ParquetValueWriters.java | 52 +-
.../iceberg/parquet/ParquetVariantReaders.java | 5 +-
.../org/apache/iceberg/parquet/TestParquet.java | 38 +-
.../iceberg/parquet/TestParquetValueWriters.java | 65 +
.../apache/iceberg/parquet/TestVariantMetrics.java | 31 +-
settings.gradle | 9 -
.../posts/2026-09-26-iceberg-cpp-0.4.0-release.md | 110 ++
.../posts/2026-10-01-iceberg-go-0.7.0-release.md | 176 ++
site/docs/contribute.md | 2 +-
site/docs/flink-quickstart.md | 6 +-
site/docs/integrations/daft.md | 4 +-
site/docs/multi-engine-support.md | 2 +-
site/docs/releases.md | 216 ++-
site/docs/spark-quickstart.md | 55 +-
site/docs/terms.md | 2 +-
site/mkdocs.yml | 4 +-
site/nav.yml | 3 +-
site/requirements.txt | 2 +-
.../extensions/TestMigrateTableProcedure.java | 2 +-
spark/v3.5/spark-runtime/LICENSE | 62 +
spark/v3.5/spark-runtime/NOTICE | 14 +-
.../spark/actions/RewriteManifestsSparkAction.java | 2 +-
.../spark/data/vectorized/ColumnarBatchUtil.java | 107 ++
.../apache/iceberg/spark/TestSparkTableUtil.java | 19 +-
.../spark/actions/TestRewriteManifestsAction.java | 36 +
.../data/vectorized/TestColumnarBatchUtil.java | 166 +-
.../spark/source/TestWriteMetricsConfig.java | 2 +-
.../extensions/TestMigrateTableProcedure.java | 2 +-
spark/v4.0/spark-runtime/LICENSE | 62 +
spark/v4.0/spark-runtime/NOTICE | 14 +-
.../spark/actions/RewriteManifestsSparkAction.java | 2 +-
.../spark/data/vectorized/ColumnarBatchUtil.java | 107 ++
.../apache/iceberg/spark/source/SparkBatch.java | 4 +-
.../apache/iceberg/spark/TestSparkTableUtil.java | 19 +-
.../spark/actions/TestRewriteManifestsAction.java | 36 +
.../data/vectorized/TestColumnarBatchUtil.java | 166 +-
.../spark/source/TestWriteMetricsConfig.java | 2 +-
.../extensions/TestMigrateTableProcedure.java | 2 +-
spark/v4.1/spark-runtime/LICENSE | 62 +
spark/v4.1/spark-runtime/NOTICE | 14 +-
.../org/apache/iceberg/spark/SparkWriteConf.java | 5 +-
.../spark/actions/RewriteManifestsSparkAction.java | 2 +-
.../spark/data/vectorized/ColumnarBatchUtil.java | 107 ++
.../apache/iceberg/spark/source/SparkBatch.java | 4 +-
.../apache/iceberg/spark/TestSparkTableUtil.java | 19 +-
.../apache/iceberg/spark/TestSparkWriteConf.java | 26 +
.../spark/actions/TestRewriteDataFilesAction.java | 31 +
.../spark/actions/TestRewriteManifestsAction.java | 36 +
.../data/vectorized/TestColumnarBatchUtil.java | 166 +-
.../spark/source/TestWriteMetricsConfig.java | 2 +-
.../org/apache/iceberg/spark/sql/TestSelect.java | 17 +
.../spark/extensions/TestCachedTableRefresh.java | 2 -
.../extensions/TestMigrateTableProcedure.java | 2 +-
spark/v4.2/spark-runtime/LICENSE | 62 +
spark/v4.2/spark-runtime/NOTICE | 14 +-
.../action/IcebergDataCompactionBenchmark.java | 9 +-
.../action/IcebergSortCompactionBenchmark.java | 8 +-
.../java/org/apache/iceberg/spark/BaseCatalog.java | 7 +
.../org/apache/iceberg/spark/SparkCatalog.java | 49 +-
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 35 +
.../apache/iceberg/spark/SparkSessionCatalog.java | 43 +-
.../org/apache/iceberg/spark/SparkTypeToType.java | 80 +-
.../org/apache/iceberg/spark/SparkV2Filters.java | 8 +-
.../actions/BaseTableCreationSparkAction.java | 10 +-
.../spark/actions/RewriteManifestsSparkAction.java | 2 +-
.../spark/data/vectorized/ColumnarBatchUtil.java | 107 ++
.../iceberg/spark/source/BaseSparkScanBuilder.java | 27 +-
.../apache/iceberg/spark/source/SparkBatch.java | 4 +-
.../iceberg/spark/source/SparkBatchQueryScan.java | 15 +-
.../iceberg/spark/source/SparkCopyOnWriteScan.java | 15 +-
.../spark/source/SparkIncrementalAppendScan.java | 15 +-
.../spark/source/SparkPartitioningAwareScan.java | 125 +-
.../spark/source/SparkRuntimeFilterableScan.java | 13 +-
.../iceberg/spark/source/SparkScanBuilder.java | 8 +
.../iceberg/spark/source/StructInternalRow.java | 6 +-
.../iceberg/spark/TestSparkSessionCatalog.java | 24 +-
.../apache/iceberg/spark/TestSparkTableUtil.java | 19 +-
.../actions/TestRemoveOrphanFilesAction3.java | 41 +-
.../spark/actions/TestRewriteManifestsAction.java | 36 +
.../data/vectorized/TestColumnarBatchUtil.java | 166 +-
.../iceberg/spark/source/TestFilteredScan.java | 90 +-
.../iceberg/spark/source/TestPathIdentifier.java | 14 +-
.../spark/source/TestWriteMetricsConfig.java | 2 +-
.../iceberg/spark/sql/TestFilterPushDown.java | 191 ++
.../iceberg/spark/sql/TestSparkDefaultValues.java | 178 +-
839 files changed, 9628 insertions(+), 118395 deletions(-)
rename aws/src/integration/java/org/apache/iceberg/aws/s3/{MinioUtil.java =>
ObjectStoreUtil.java} (51%)
rename aws/src/integration/java/org/apache/iceberg/aws/s3/{TestMinioUtil.java
=> TestObjectStoreUtil.java} (91%)
delete mode 100644
aws/src/integration/java/org/apache/iceberg/aws/s3/TestS3FileIOWithLegacyMinIO.java
create mode 100644
aws/src/test/java/org/apache/iceberg/aws/s3/TestS3FileIOLegacyMd5.java
create mode 100644
core/src/jmh/java/org/apache/iceberg/deletes/PositionDeleteIndexBenchmark.java
create mode 100644 core/src/main/java/org/apache/iceberg/SchemaOrder.java
copy api/src/main/java/org/apache/iceberg/UpdateLocation.java =>
core/src/main/java/org/apache/iceberg/SupportsLabels.java (67%)
copy
core/src/main/java/org/apache/iceberg/rest/responses/{LoadViewResponse.java =>
UnregisterTableResponse.java} (60%)
create mode 100644
core/src/main/java/org/apache/iceberg/rest/responses/UnregisterTableResponseParser.java
copy core/src/{main/java/org/apache/iceberg/Labels.java =>
test/java/org/apache/iceberg/MetricsTestUtil.java} (51%)
create mode 100644
core/src/test/java/org/apache/iceberg/TestLabelsOnBaseTable.java
create mode 100644 core/src/test/java/org/apache/iceberg/TestSchemaOrder.java
create mode 100644
core/src/test/java/org/apache/iceberg/rest/TestRESTCatalogLabels.java
create mode 100644
core/src/test/java/org/apache/iceberg/rest/responses/TestUnregisterTableResponseParser.java
delete mode 100644 flink/v2.1/build.gradle
delete mode 100644 flink/v2.1/flink-runtime/LICENSE
delete mode 100644 flink/v2.1/flink-runtime/NOTICE
delete mode 100644 flink/v2.1/flink-runtime/runtime-deps.txt
delete mode 100644
flink/v2.1/flink-runtime/src/integration/java/org/apache/iceberg/flink/TestIcebergConnectorSmoke.java
delete mode 100644
flink/v2.1/flink/src/jmh/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordSerializerDeserializerBenchmark.java
delete mode 100644
flink/v2.1/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java
delete mode 100644
flink/v2.1/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/SketchRangePartitionerBenchmark.java
delete mode 100644
flink/v2.1/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/StatisticsRecordSerializerBenchmark.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/flink/table/api/runtime/types/FlinkScalaKryoInstantiator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/flink/types/variant/BinaryVariantAccessorUtils.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkCreateTableOptions.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkRowData.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkFormatModels.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkPlannedAvroReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/FlinkVariantShreddingAnalyzer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/data/VariantRowDataWrapper.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/formats/avro/AvroToRowDataConverters.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/formats/avro/JodaConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/formats/avro/RowDataToAvroConverters.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/formats/avro/typeutils/AvroSchemaConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ConvertEqualityDeletes.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ConvertEqualityDeletesConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/DeleteOrphanFiles.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/DeleteOrphanFilesConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ExpireSnapshots.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ExpireSnapshotsConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/FlinkMaintenanceConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/JdbcLockFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/LockConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFilesConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TableMaintenance.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TaskResult.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/Trigger.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TriggerLockFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ZKRetryPolicies.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ZkLockFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/BaseCoordinator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DVPosition.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DVWriteResult.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteRunner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DeleteFilesProcessor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityConvertCommitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityConvertDVWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityConvertPKIndex.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityConvertPlan.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityConvertPlanner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityConvertReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/EqualityDeleteFileScanTask.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ExpireSnapshotsProcessor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/FileNameReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/FileUriKeySelector.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/FlinkAddedRowsScanTask.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/IndexCommand.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ListFileSystemFiles.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ListMetadataFiles.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockFactoryBuilder.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRegisterEvent.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockReleaseEvent.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemoverCoordinator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemoverOperator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemoverOperatorFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MetadataTablePlanner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/OrphanFilesDetector.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ReadCommand.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SerializedEqualityValues.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SkipOnError.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/StructLikeSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResultAggregator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerEvaluator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManager.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManagerCoordinator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManagerOperator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManagerOperatorFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/CommittableToTableChangeConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkBuilder.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/CompareSchemasVisitor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DataConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicCommittable.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicCommittableSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicCommitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicCommitterMetrics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecord.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordGenerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternal.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternalSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternalType.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordProcessor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordWithConfig.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicSinkUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicTableRecordGenerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicTableUpdateOperator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicWriteResult.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicWriteResultAggregator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicWriteResultSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicWriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicWriterMetrics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/EvolveSchemaVisitor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/FlinkDynamicSinkConf.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/FlinkDynamicSinkOptions.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/HashKeyGenerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/JobOperatorKey.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/LRUCache.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/PartitionSpecEvolution.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableCreator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableKey.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableMetadataCache.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableSerializerCache.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableUpdater.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/VariantAvroDynamicTableRecordGenerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/WriteTarget.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatisticsSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatistics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatisticsSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/KeyAssignment.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapAssignment.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RangePartitioner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RequestGlobalStatisticsEvent.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchDataStatistics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchRangePartitioner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySketchSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeyUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsEvent.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecord.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordTypeInformation.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsType.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/LimitableDataIterator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/PoolWithWakeup.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordLimiter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/WakeableIterator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java
delete mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/util/SerializerHelper.java
delete mode 100644
flink/v2.1/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/AvroGenericRecordConverterBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/CatalogTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/DataGenerator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogExtension.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/HadoopTableExtension.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/SqlBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestCatalogLoader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestDataFileSerialization.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkAnonymousTable.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogView.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogViewIncapableCatalog.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkFilters.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkRESTCatalogDatabase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkReadConf.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkSchemaUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSinkCompaction.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSinkExtended.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUnknownType.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUuidType.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkVariantShreddingType.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkVariantType.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestHelpers.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestManifestFileSerialization.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestRowDataWrapper.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/RandomRowData.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/RowDataToRowMapper.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkFormatModel.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkVariants.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestRowDataProjection.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestStructRowData.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestVariantRowDataWrapper.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskInfraExtension.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestConvertEqualityDeletes.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestConvertEqualityDeletesConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestConvertEqualityDeletesE2E.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestDeleteOrphanFiles.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestDeleteOrphanFilesConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestExpireSnapshots.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestExpireSnapshotsConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestJdbcLockFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestLockFactoryBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestMaintenanceE2E.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFilesConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestTableMaintenance.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestTableMaintenanceCoordinationLock.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestZkLockFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CoordinatorTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/MetricsReporterFactoryForTests.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/RewriteUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestDataFileRewriteCommitter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestDataFileRewritePlanner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestDataFileRewriteRunner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestDeleteFilesProcessor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestEqualityConvertCommitter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestEqualityConvertDVWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestEqualityConvertPKIndex.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestEqualityConvertPlanner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestEqualityConvertReader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestExpireSnapshotsProcessor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestFlinkPojoTypes.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestListFileSystemFiles.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestListMetadataFiles.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockFactoryBuilder.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemoveCoordinator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemover.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemoverOperation.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestOrphanFilesDetector.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestSkipOnError.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestStructLikeSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTablePlanerAndReader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTaskResultAggregator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManagerCoordinator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManagerOperator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/SinkTestUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestAvroGenericRecordToRowDataMapper.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionKeySelector.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitioner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerFlinkIcebergSink.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestCommittableToTableChangeConverter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkFileWriterFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkDistributionMode.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkExtended.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2DistributionMode.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPositionDeltaWriters.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkRollingFileWriters.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkWriterMetrics.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergCommitter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSink.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkBranch.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkTableMaintenance.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2Branch.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriterMetrics.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestManifestOutputFileFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestRowDataPartitionKey.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternalSerializerTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestCompareSchemasVisitor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicCommittableSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicCommitter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSink.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSinkPerf.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializerWriteSchema.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializerWriteSchemaId.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializerWriteSchemaIdLongUTF.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializerWriteSchemaLongUTF.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordProcessor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordWithConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicTableUpdateOperator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicWriteResultAggregator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicWriteResultSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicWriter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestEvolveSchemaVisitor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestHashKeyGenerator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestLRUCache.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestPartitionSpecEvolution.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestRowDataConverter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestTableMetadataCache.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestTableSerializerCache.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestTableUpdater.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestVariantAvroDynamicTableRecordGenerator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/DataDistributionUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/Fixtures.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestAggregatedStatisticsTracker.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestCompletedStatisticsSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataDistributionUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinatorProvider.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsOperator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestGlobalStatisticsSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapDataStatistics.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapRangePartitioner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestRangePartitioner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestRangePartitionerSkew.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSketchDataStatistics.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSketchRangePartitioner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSketchUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerNestedStruct.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerPrimitives.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerSnapshot.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeyUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestStatisticsOrRecordSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestStatisticsOrRecordTypeInformation.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTestSource.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/SplitHelpers.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TableSourceTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceConfig.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBounded.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedConverterBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedGenericRecord.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedRow.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceInferParallelism.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceReaderDeletes.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpeculativeExecutionSupport.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestMetadataTableReadableMetrics.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestRowDataToAvroGenericRecordConverter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestScanContext.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/assigner/SplitAssignerTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestDefaultSplitAssigner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestFileSequenceNumberBasedSplitAssigner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousIcebergEnumerator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestEnumerationHistory.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestIcebergEnumeratorStateSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayBatchRecords.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherRowData.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherWakeup.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestLimitableDataIterator.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestPoolWithWakeup.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestWatermarkExtractorRecordEmitter.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestingMetricGroup.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/source/split/TestIcebergSourceSplitSerializer.java
delete mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java
delete mode 100644
flink/v2.1/flink/src/test/resources/META-INF/services/org.apache.flink.metrics.reporter.MetricReporterFactory
delete mode 100644
flink/v2.1/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestCoordinatorFencing.java
create mode 100644 site/docs/blog/posts/2026-09-26-iceberg-cpp-0.4.0-release.md
create mode 100644 site/docs/blog/posts/2026-10-01-iceberg-go-0.7.0-release.md
