[jira] [Created] (FLINK-15092) Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException

[Shang Yuanchun (Jira)]

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)