Skip to content

Flink: Backport: Filter CatalogTable properties#16318

Open
pvary wants to merge 1 commit into
apache:mainfrom
pvary:catalog_table_back
Open

Flink: Backport: Filter CatalogTable properties#16318
pvary wants to merge 1 commit into
apache:mainfrom
pvary:catalog_table_back

Conversation

@pvary
Copy link
Copy Markdown
Contributor

@pvary pvary commented May 13, 2026

Backport of #16313.

Clean backport with a single exception:

      // `type` option is filtered out by Flink
      // https://github.com/apache/flink/blob/edc3d68736de73665440f4313ddcfd9142d8d42b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java#L378
      Map<String, String> filteredOptions = Maps.newHashMap(config);
      filteredOptions.remove(CommonCatalogOptions.CATALOG_TYPE.key());

The snippet above doesn't apply for Flink 1.20, so it is removed.

@github-actions github-actions Bot added the flink label May 13, 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.

2 participants