[jira] [Commented] (FLINK-32289) The metadata column type is incorrect in Kafka table connector example

2023-06-13 Thread Leonard Xu (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-32289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732110#comment-17732110
 ] 

Leonard Xu commented on FLINK-32289:


Fixed in：

flink(master)： 5326cb4528a02ecbe8f68ff1ece31e9305050162
flink-connector-kafka(main): aee4e82397af082e0463ffc156ae215132aa2b57

 

> 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.15.4, 1.16.2, 1.17.1
>Reporter: Leonard Xu
>Assignee: Xiqian YU
>Priority: Major
>  Labels: pull-request-available
>
> 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)

[jira] [Commented] (FLINK-32289) The metadata column type is incorrect in Kafka table connector example

2023-06-08 Thread Xiqian YU (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-32289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730478#comment-17730478
 ] 

Xiqian YU commented on FLINK-32289:
---

I'm glad to take this ticket.

> 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.15.4, 1.16.2, 1.17.1
>Reporter: Leonard Xu
>Priority: Major
>
> 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)