[jira] [Commented] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different

2019-12-19 Thread Jingsong Lee (Jira) 


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

Jingsong Lee commented on FLINK-15310:
--

This is duplicated to FLINK-15313 , so I mark this a major, we can verify after 
fixing.

> A timestamp result get by a select sql and a csvsink sql is different
> -
>
> Key: FLINK-15310
> URL: https://issues.apache.org/jira/browse/FLINK-15310
> Project: Flink
>  Issue Type: Bug
>  Components: Table SQL / Client
>Affects Versions: 1.10.0
> Environment: execution:
>   planner: blink
>   type: batch
>Reporter: xiaojin.wy
>Priority: Critical
> Fix For: 1.10.0
>
> Attachments: image-2019-12-18-16-33-24-510.png
>
>
> *The sql is:*
> CREATE TABLE `orders` (
>   rowtime TIMESTAMP,
>   id  INT,
>   product VARCHAR,
>   units INT
> ) WITH (
>   'format.field-delimiter'='|',
>   'connector.type'='filesystem',
>   'format.derive-schema'='true',
>   
> 'connector.path'='/defender_test_data/daily_regression_blink_sql_1.10/test_agg/sources/orders.csv',
>   'format.type'='csv'
> );
> select floor(rowtime to hour) as rowtime, count(*) as c from orders group by 
> floor(rowtime to hour)
> The result got in a sqlClient environment which use the sql above is like 
> this:
>  !image-2019-12-18-16-33-24-510.png! 
> But the same sql write directly to a cvs batch sink will get a result like 
> this:
> 1972-03-06 08:44:36.736|4
> 1972-03-06 08:44:36.736|1



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

[jira] [Commented] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different

2019-12-18 Thread xiaojin.wy (Jira) 


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

xiaojin.wy commented on FLINK-15310:


[~danny0405]

> A timestamp result get by a select sql and a csvsink sql is different
> -
>
> Key: FLINK-15310
> URL: https://issues.apache.org/jira/browse/FLINK-15310
> Project: Flink
>  Issue Type: Bug
>  Components: Table SQL / Client
>Affects Versions: 1.10.0
> Environment: execution:
>   planner: blink
>   type: batch
>Reporter: xiaojin.wy
>Priority: Major
> Attachments: image-2019-12-18-16-33-24-510.png
>
>
> *The sql is:*
> CREATE TABLE `orders` (
>   rowtime TIMESTAMP,
>   id  INT,
>   product VARCHAR,
>   units INT
> ) WITH (
>   'format.field-delimiter'='|',
>   'connector.type'='filesystem',
>   'format.derive-schema'='true',
>   
> 'connector.path'='/defender_test_data/daily_regression_blink_sql_1.10/test_agg/sources/orders.csv',
>   'format.type'='csv'
> );
> select floor(rowtime to hour) as rowtime, count(*) as c from orders group by 
> floor(rowtime to hour)
> The result got in a sqlClient environment which use the sql above:
>  !image-2019-12-18-16-33-24-510.png! 
> But sql same sql directly write to a cvs batch sink will get a result like 
> this:
> 1972-03-06 08:44:36.736|4
> 1972-03-06 08:44:36.736|1



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