Leonard Xu created FLINK-32289: ---------------------------------- Summary: The metadata column type is incorrect in Kafka table connector example Key: FLINK-32289 URL: https://issues.apache.org/jira/browse/FLINK-32289 Project: Flink Issue Type: Bug Components: Connectors / Kafka Affects Versions: 1.17.1, 1.16.2, 1.15.4 Reporter: Leonard Xu
The example[1] defined ts column with TIMESTAMP type {code:java} `ts` TIMESTAMP(3) METADATA FROM 'timestamp' {code} the correct column type should be TIMESTAMP_LTZ type. {code:java} `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp' {code} [1] https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/kafka/#how-to-create-a-kafka-table -- This message was sent by Atlassian Jira (v8.20.10#820010)