Skip to content

[FLINK-39797] Support disabling automatic table creation#4420

Draft
litiliu wants to merge 1 commit into
apache:masterfrom
litiliu:FLINK-39797-disable-auto-create-table
Draft

[FLINK-39797] Support disabling automatic table creation#4420
litiliu wants to merge 1 commit into
apache:masterfrom
litiliu:FLINK-39797-disable-auto-create-table

Conversation

@litiliu
Copy link
Copy Markdown

@litiliu litiliu commented May 29, 2026

What is the purpose of the change

This pull request adds a Fluss pipeline sink option to disable automatic target table creation. When auto.create.table.enabled is set to false, the Fluss sink fails fast if the target table does not already exist, while preserving the existing default behavior of automatically creating tables.

JIRA: https://issues.apache.org/jira/browse/FLINK-39797

Brief change log

  • Added optional Fluss sink option auto.create.table.enabled with default value true.
  • Wired the option through FlussDataSinkFactory, FlussDataSink, and FlussMetaDataApplier.
  • Updated create-table handling so missing target tables fail with ValidationException when automatic table creation is disabled.
  • Kept database auto-creation and existing-table sanity checks unchanged.
  • Added unit/integration coverage for accepting the new option and disabled auto-create behavior.

Verifying this change

This change is covered by existing and newly added tests.

Verified locally with:

mvn -pl flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss -am -Dtest=FlussDataSinkFactoryTest,FlussMetadataApplierTest -DfailIfNoTests=false test

Result: Tests run: 19, Failures: 0, Errors: 0, Skipped: 0.

Documentation

Updated the English and Chinese Fluss pipeline connector documentation to describe auto.create.table.enabled and the pre-created table mode.

@github-actions github-actions Bot added the docs Improvements or additions to documentation label May 29, 2026
@litiliu litiliu marked this pull request as draft May 29, 2026 08:14
@litiliu litiliu changed the title [FLINK-39797][fluss] Support disabling automatic table creation [FLINK-39797] Support disabling automatic table creation May 29, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

docs Improvements or additions to documentation

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant