You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/10 02:57:00 UTC

[jira] [Commented] (FLINK-17948) Use new type system for SQL Client collect sink

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

Jark Wu commented on FLINK-17948:
---------------------------------

A user also reported TIMESTAMP WITH LOCAL TIME ZONE type can't be used in SQL Client query. 

http://apache-flink.147419.n8.nabble.com/flink-sql-postgres-timestamp-td9235.html

> Use new type system for SQL Client collect sink
> -----------------------------------------------
>
>                 Key: FLINK-17948
>                 URL: https://issues.apache.org/jira/browse/FLINK-17948
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Client
>    Affects Versions: 1.11.0
>         Environment: mysql:
>  image: mysql:8.0
>  volumes:
>  - ./mysql/mktable.sql:/docker-entrypoint-initdb.d/mktable.sql
>  environment:
>  MYSQL_ROOT_PASSWORD: 123456
>  ports:
>  - "3306:3306"
>            Reporter: Shengkai Fang
>            Assignee: godfrey he
>            Priority: Major
>             Fix For: 1.13.0
>
>         Attachments: image-2020-05-26-22-56-43-835.png, image-2020-05-26-22-58-02-326.png
>
>
> My job is following:
>  
> {code:java}
> CREATE TABLE currency (
>   currency_id BIGINT,
>   currency_name STRING,
>   rate DOUBLE,
>   currency_timestamp  TIMESTAMP,
>   country STRING,
>   precise_timestamp TIMESTAMP(6),
>   precise_time TIME(6),
>   gdp DECIMAL(10, 6)
> ) WITH (
>    'connector' = 'jdbc',
>    'url' = 'jdbc:mysql://localhost:3306/flink',
>    'username' = 'root',
>    'password' = '123456',
>    'table-name' = 'currency',
>    'driver' = 'com.mysql.jdbc.Driver',
>    'lookup.cache.max-rows' = '500',
>    'lookup.cache.ttl' = '10s',
>    'lookup.max-retries' = '3')
> {code}
> When select * from currency, the precision of results are not as same as expected.  The precision of field precise_timestamp is 3 not 6, and the field gdp has more digit as expected. 
>  
> !image-2020-05-26-22-56-43-835.png!
> The data in mysql is following:
> !image-2020-05-26-22-58-02-326.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)