[FLINK-26712] Metadata keys should not conflict with physical columns

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 17/Mar/22 14:20
• Updated: 04/Apr/22 12:09
• Resolved: 04/Apr/22 12:09

Description

If you have an field called timestamp and in addition want to read the timestamp from the metadata:

CREATE TABLE animal_sightings_with_metadata (
  `timestamp` TIMESTAMP(3),
  `name` STRING,
  `country` STRING,
  `number` INT,
  `append_time` TIMESTAMP(3) METADATA FROM 'timestamp',
  `partition` BIGINT METADATA VIRTUAL,
  `offset` BIGINT METADATA VIRTUAL,
  `headers` MAP<STRING, BYTES> METADATA,
  `timestamp-type` STRING METADATA,
  `leader-epoch` INT METADATA,
  `topic` STRING METADATA
)

This gives:

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Field names must be unique. Found duplicates: [timestamp]

Issue Links

• links to: GitHub Pull Request #19236