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)