Skip to content

[flink] Fix CSV delimiter fallback for format tables - #9178

Open
ArnavBalyan wants to merge 1 commit into
apache:masterfrom
ArnavBalyan:arnavb/flink-dem
Open

[flink] Fix CSV delimiter fallback for format tables#9178
ArnavBalyan wants to merge 1 commit into
apache:masterfrom
ArnavBalyan:arnavb/flink-dem

Conversation

@ArnavBalyan

Copy link
Copy Markdown
Member

Purpose

  • CSV format tables ignore the seq and delimiter fallback options in Flink.
  • This is because FormatCatalogTable only propagates CSV prefixed options and explicitly maps field-delimiter.
  • Fix this by resolving CsvOptions.FIELD_DELIMITER and forwarding the canonical option so all fallback keys are supported.

Tests

  • UT

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.

1 participant