xiaojin.wy created FLINK-15246:
----------------------------------

             Summary: Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL]   
not equal to TableSink schema:    [EXPR$0: TIMESTAMP(3)]
                 Key: FLINK-15246
                 URL: https://issues.apache.org/jira/browse/FLINK-15246
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Client
    Affects Versions: 1.10.0
            Reporter: xiaojin.wy


When I excute the sql below and check the result of it, the "Query result 
schema" is not equal to the "TableSink schema";

 

 

The sql is:

CREATE TABLE `t` (
 x INT
) WITH (
 'format.field-delimiter'=',',
 'connector.type'='filesystem',
 'format.derive-schema'='true',
 
'connector.path'='/defender_test_data/daily_regression_batch_spark_1.10/test_case_when_coercion/sources/t.csv',
 'format.type'='csv'
);

SELECT CASE WHEN true THEN cast('2017-12-12 09:30:00.0' as timestamp) ELSE 
cast(2 as tinyint) END FROM t;

 

The exception is:

org.apache.flink.table.api.ValidationException: Field types of query result and 
registered TableSink 
`default_catalog`.`default_database`.`_tmp_table_443938765` do not match. Query 
result schema: [EXPR$0: TIMESTAMP(6) NOT NULL] TableSink schema: [EXPR$0: 
TIMESTAMP(3)]

 

The input data is:

1



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

Reply via email to