Skip to content

Conversation

@jeffxiang
Copy link
Contributor

@jeffxiang jeffxiang commented Dec 17, 2025

Currently, PscDynamicTableFactory and UpserPscDynamicTableFactory will reject DDL's which contain configs other than the ones defined to be relevant to the connector. This does not allow users to supply additional metadata into the DDL's for various purposes, such as cataloging.

This PR allows for table metadata configs which are irrelevant to the connector to be passed into the FlinkSQL PSC connector DDL's. For example, if users want to supply table metadata for cataloging purposes, they can do so by prefixing those fields with metadata..

Example:

CREATE TABLE psc_test_source (
   ...
) WITH (
  'connector' = 'psc',
  'scan.startup.mode' = 'group-offsets',
  ...
  'metadata.table-description' = 'foo',
  'metadata.table-tiering' = '2'
)

Also bumping version to 4.1.4-SNAPSHOT

@jeffxiang jeffxiang requested a review from a team as a code owner December 17, 2025 21:02
@jeffxiang jeffxiang merged commit d2fea69 into 4.0 Dec 17, 2025
2 checks passed
@jeffxiang jeffxiang deleted the bump_version branch December 17, 2025 22:50
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants