xiaojin.wy created FLINK-15092: ---------------------------------- Summary: Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException Key: FLINK-15092 URL: https://issues.apache.org/jira/browse/FLINK-15092 Project: Flink Issue Type: Bug Components: Table SQL / Client Affects Versions: 1.10.0 Environment: flink master's newest code. Reporter: xiaojin.wy
CREATE TABLE `t123` ( x INT ) WITH ( 'format.field-delimiter'='|', 'connector.type'='filesystem', 'format.derive-schema'='true', 'connector.path'='hdfs://zthdev/defender_test_data/daily/test_aggregates/sources/t123.csv', 'format.type'='csv' ); select sum(cast(null as int)) from t123; Excute the statement above , then you will see such exception: [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.TableException: Failed to push project into table source! table source with pushdown capability must override and change explainSource() API to explain the pushdown applied! -- This message was sent by Atlassian Jira (v8.3.4#803005)