Skip to content

Flink: Dynamic Sink: Resolve effective write config at runtime - #15237

Merged
pvary merged 2 commits into
apache:mainfrom
mxm:write-properties
Feb 5, 2026
Merged

pvary merged 2 commits into
apache:mainfrom
mxm:write-properties

Conversation

@mxm

@mxm mxm commented Feb 5, 2026

Copy link
Copy Markdown
Contributor

The default write properties constructed at the Dynamic Sink builder-level let to overriding properties set at the table properties level. To properly resolve the effective config, property resolution had to be deferred to runtime where the table properties for a given table are available.

This closes #15225.

The default write properties constructed at the Dynamic Sink builder-level let
to overriding properties set at the table properties level. To properly resolve
the effective config, property resolution had to be deferred to runtime where
the table properties for a given table are available.
@github-actions github-actions Bot added the flink label Feb 5, 2026
@pvary
pvary merged commit ccf4d91 into apache:main Feb 5, 2026
14 checks passed
@pvary

pvary commented Feb 5, 2026

Copy link
Copy Markdown
Contributor

Merged to main.
Thanks @mxm for the quick fix!

@mxm
mxm deleted the write-properties branch February 5, 2026 15:35
mxm added a commit to mxm/iceberg that referenced this pull request Feb 6, 2026
pvary pushed a commit that referenced this pull request Feb 6, 2026
talatuyarer pushed a commit to talatuyarer/iceberg that referenced this pull request Apr 1, 2026
talatuyarer pushed a commit to talatuyarer/iceberg that referenced this pull request Apr 1, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Flink: DynamicIcebergSink ignores table-level compression codec settings

2 participants