Skip to content

Connect: 1.11.x error handling dlq#5

Open
devendra-nr wants to merge 756 commits into
1.9.x_error_handling_dlqfrom
1.11.x_error_handling_dlq
Open

Connect: 1.11.x error handling dlq#5
devendra-nr wants to merge 756 commits into
1.9.x_error_handling_dlqfrom
1.11.x_error_handling_dlq

Conversation

@devendra-nr

Copy link
Copy Markdown
Owner

No description provided.

dramaticlly and others added 30 commits March 30, 2026 11:26
…15748)

* [Core] Fix NPE of generateRandomMetrics in FileGenerationUtil

* Address review feedback
…ing to 2.0.3 (apache#15440)

* Bump aircompressor to 2.0.3 globally to fix CVE-2025-67721

Update the central version in libs.versions.toml from 0.27 to 2.0.3
and update the version reference in open-api/LICENSE.

* Enforce aircompressor 2.0.3 globally via dependency substitution

Add a substitute rule in build.gradle to enforce aircompressor 2.0.3
across all modules, following the same pattern used for lz4-java.
…5823)

* Remove Spark 2 test assumptions for write projection

* apply formatting

* remove dead code for spark 2

* revert partial column fix for 3.4, 3.5 and 4.0

* remove spark 2 testing in 3.4, 3.5 and 4.0
flinkVersions=1.14 is End of Life and was removed from the Iceberg
build. Any new contributor copying this command gets a hard Gradle
exception. Update to current supported versions (1.20, 2.0) and
update Spark versions to more current ones (3.5, 4.0).
* REST: Promote the S3 signing endpoint to the main spec

Dev ML discussion: https://lists.apache.org/thread/2kqdqb46j7jww36wwg4txv6pl2hqq9w7

This commit promotes the S3 remote signing endpoint from an AWS-specific implementation to a first-class REST catalog API endpoint.

This enables other storage providers (GCS, Azure, etc.) to eventually reuse the same signing endpoint pattern without duplicating the API definition.

Summary of changes:

- Added `/v1/{prefix}/namespaces/{namespace}/tables/{table}/sign/{provider}` endpoint to the main REST catalog OpenAPI spec.
- Defined `RemoteSignRequest`, `RemoteSignResult` and `RemoteSignResponse` schemas.
- Defined a new `provider` request body parameter in order to disambiguate requests from different storage providers.
- Deprecated the separate `s3-signer-open-api.yaml` spec from the AWS module (for removal).
- Updated the Python client.
…he#15049)

Introduces foundational types for V4 manifest support

These types follow the https://s.apache.org/iceberg-single-file-commit
and will be used by subsequent PRs for manifest reading/writing.

For now, we are adding these as package-private interfaces in core, and
eventually we will move them into api.
…5734)

Signal to the TableOperations that there is no retry needed for files which do not exist.
…5825)

* Spark: Control merge schema evolution by table property

Add a new table property write.spark.auto-schema-evolution (default true)
that controls whether the AUTOMATIC_SCHEMA_EVOLUTION capability is
reported to Spark. When set to false, Spark's MERGE WITH SCHEMA
EVOLUTION no longer evolves the target table schema.

Also add a guard in SparkWriteBuilder to reject mergeSchema write option
when the property is disabled.

* Remove unnecessary validation from SparkWriteBuilder

The capability removal in SparkTable is sufficient to control schema
evolution. The mergeSchema write option path already requires
accept-any-schema, making a second gate redundant.

* Address review comments

- Rename property to write.spark.auto-schema-evolution.enabled
- Rename caps to tableCapabilities in computeCapabilities
- Add explicit = in ALTER TABLE SET TBLPROPERTIES test SQL
This fixes Russell's feedback on apache#15049
to avoid version-specific language that will go stale.
Adds a build-time check that prevents accidental transitive dependency
leaks into shipped shadow JARs and distribution archives. A checked-in
runtime-deps.txt baseline lists every dependency resolved into each
bundled artifact. checkRuntimeDeps compares resolved deps against the
baseline and fails the build with a clear diff on mismatch, wired into
the check lifecycle so it runs in CI automatically.

This guards all 11 bundled modules: Spark runtime (3.4, 3.5, 4.0, 4.1),
Flink runtime (1.20, 2.0, 2.1), cloud bundles (AWS, Azure, GCP), and
Kafka Connect runtime.
Co-authored-by: manuzhang <owenzhang1990@gmail.com>
Bumps [mkdocs-redirects](https://github.com/ProperDocs/properdocs-redirects) from 1.2.2 to 1.2.3.
- [Release notes](https://github.com/ProperDocs/properdocs-redirects/releases)
- [Commits](ProperDocs/mkdocs-redirects@v1.2.2...v1.2.3)

---
updated-dependencies:
- dependency-name: mkdocs-redirects
  dependency-version: 1.2.3
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps [astral-sh/setup-uv](https://github.com/astral-sh/setup-uv) from 7.6.0 to 8.0.0.
- [Release notes](https://github.com/astral-sh/setup-uv/releases)
- [Commits](astral-sh/setup-uv@37802ad...cec2083)

---
updated-dependencies:
- dependency-name: astral-sh/setup-uv
  dependency-version: 8.0.0
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…15886)

Bumps [org.openapitools:openapi-generator-gradle-plugin](https://github.com/OpenAPITools/openapi-generator) from 7.20.0 to 7.21.0.
- [Release notes](https://github.com/OpenAPITools/openapi-generator/releases)
- [Changelog](https://github.com/OpenAPITools/openapi-generator/blob/master/docs/release-summary.md)
- [Commits](OpenAPITools/openapi-generator@v7.20.0...v7.21.0)

---
updated-dependencies:
- dependency-name: org.openapitools:openapi-generator-gradle-plugin
  dependency-version: 7.21.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…pache#15889)

Bumps [com.google.cloud:libraries-bom](https://github.com/googleapis/java-cloud-bom) from 26.78.0 to 26.79.0.
- [Release notes](https://github.com/googleapis/java-cloud-bom/releases)
- [Commits](googleapis/java-cloud-bom@v26.78.0...v26.79.0)

---
updated-dependencies:
- dependency-name: com.google.cloud:libraries-bom
  dependency-version: 26.79.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…e#15890)

Bumps software.amazon.awssdk:bom from 2.42.18 to 2.42.23.

---
updated-dependencies:
- dependency-name: software.amazon.awssdk:bom
  dependency-version: 2.42.23
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps `jetty` from 12.1.5 to 12.1.7.

Updates `org.eclipse.jetty:jetty-server` from 12.1.5 to 12.1.7

Updates `org.eclipse.jetty.ee10:jetty-ee10-servlet` from 12.1.5 to 12.1.7

---
updated-dependencies:
- dependency-name: org.eclipse.jetty:jetty-server
  dependency-version: 12.1.7
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.eclipse.jetty.ee10:jetty-ee10-servlet
  dependency-version: 12.1.7
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…pache#15891)

Bumps [io.netty:netty-buffer](https://github.com/netty/netty) from 4.2.10.Final to 4.2.12.Final.
- [Release notes](https://github.com/netty/netty/releases)
- [Commits](netty/netty@netty-4.2.10.Final...netty-4.2.12.Final)

---
updated-dependencies:
- dependency-name: io.netty:netty-buffer
  dependency-version: 4.2.12.Final
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
* AWS: Add chunked encoding configuration for S3 requests

* add testMultipartUploadWithChunkedEncodingDisabled

* update open api define

* update

* update default value

* update case

* assert file contents in testMultipartUploadWithChunkedEncoding

* Remove s3.chunked-encoding-enabled config entry from REST catalog open API spec

* Use IOUtil.readFully for reliable reads in TestS3MultipartUpload

* ensure testIo is properly closed

* retrigger CI

* Change chunked encoding default to true to match AWS SDK behavior

* Fix test to verify explicit disable of chunked encoding instead of duplicating default
* Make MAX_WAIT_TIME_MS configurable for RESTTableScan

* fix style

* fix checkstyle: add hasMessage check to assertThatThrownBy

Co-authored-by: Isaac

* Address Amogh's comments

* address comments
hantangwangd and others added 27 commits May 13, 2026 15:12
…ering (apache#16303)

* Spark: Backport migrate SparkCopyOnWriteScan to SupportsRuntimeV2Filtering

* trigger build

* Update spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteScan.java

* Update spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteScan.java

* Update spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteScan.java

* add back import

* spark 3.4: SupportsRuntimeFiltering -> SupportsRuntimeV2Filtering

---------

Co-authored-by: Kevin Liu <kevin.jq.liu@gmail.com>
Co-authored-by: Kevin Liu <kevinjqliu@users.noreply.github.com>
Agent-Logs-Url: https://github.com/kevinjqliu/iceberg/sessions/682ce8b4-890f-41a9-a89a-b1f2873be44c

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: kevinjqliu <9057843+kevinjqliu@users.noreply.github.com>
Co-authored-by: karuppayya <karuppayya1990@gmaiul.com>
…orders with dropped fields (apache#16519) (apache#16521) (apache#16779)

Co-authored-by: Yong Zheng <yongzheng0809@gmail.com>
…16759)

Backports apache#15911 to the 1.11.x release branch.

Preserve encryption key metadata when merged deletion vectors are written, and add coverage for encrypted DV merges and native key metadata file-length handling.

Co-authored-by: Codex <codex@openai.com>
@devendra-nr devendra-nr changed the title 1.11.x error handling dlq Connect: 1.11.x error handling dlq Jun 25, 2026
@devendra-nr devendra-nr changed the base branch from 1.11.x to 1.9.x_error_handling_dlq June 26, 2026 06:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.