Skip to content

[FLINK-39934][postgres] Fix invalid tables format error message#4442

Open
taoran92 wants to merge 1 commit into
apache:masterfrom
taoran92:fix-postgres-tables-error-message
Open

[FLINK-39934][postgres] Fix invalid tables format error message#4442
taoran92 wants to merge 1 commit into
apache:masterfrom
taoran92:fix-postgres-tables-error-message

Conversation

@taoran92

@taoran92 taoran92 commented Jun 15, 2026

Copy link
Copy Markdown
Member

What is the purpose of the change

This PR fixes the misleading validation error message in the Postgres pipeline connector when the configured tables value does not match the required db.schema.table format.

Previously, the error message always printed the option key tables instead of the actual invalid table value, making the configuration issue harder to diagnose.

Jira: FLINK-39934

Brief change log

  • Print the actual invalid table pattern in PostgresDataSourceFactory#getValidateDatabaseName
  • Keep the existing table format validation logic unchanged

No configuration option is added because this only improves the validation error message and does not change connector behavior.

Verifying this change

This change is verified by code inspection and git diff --check.

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): no
  • The public API, i.e. is any changed class annotated with @public(@PublicEvolving): no
  • The serializers: no
  • The runtime per-record code paths (performance sensitive): no
  • Anything that affects deployment or recovery: no

Documentation

Does this pull request introduce a new feature? no

If yes, how is the feature documented? not applicable

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.

1 participant