[ 
https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jark Wu updated FLINK-18365:
----------------------------
    Environment:     (was: I use the sql-gateway to run this sql.

*The input table is:*

 CREATE TABLE `scott_dept` (
        deptno INT,
        dname VARCHAR,
        loc VARCHAR
) WITH (
        'format.field-delimiter'='|',
        'connector.type'='filesystem',
        'format.derive-schema'='true',
        
'connector.path'='/defender_test_data/daily_regression_stream_blink_sql_1.10/test_scalar/sources/scott_dept.csv',
        'format.type'='csv'
)

*The input data is:*

10|ACCOUNTING|NEW YORK
20|RESEARCH|DALLAS
30|SALES|CHICAGO
40|OPERATIONS|BOSTON
)

> The same sql in a batch env and a streaming env has different value.
> --------------------------------------------------------------------
>
>                 Key: FLINK-18365
>                 URL: https://issues.apache.org/jira/browse/FLINK-18365
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / API
>    Affects Versions: 1.11.0
>            Reporter: xiaojin.wy
>            Priority: Major
>             Fix For: 1.11.0
>
>
> *The sql is :*
> select deptno, (select count(*) from scott_emp where 1 = 0) as x from 
> scott_dept
> *The error:*
> In a batch environment, the result value is:10|0\n20|0\n30|0\n40|0
> In a streaming environment, the result value 
> is:10|None\n20|None\n30|None\n40|None



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

Reply via email to