You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/18 12:26:00 UTC

[jira] [Created] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

xiaojin.wy created FLINK-18365:
----------------------------------

             Summary: 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
         Environment: 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

            Reporter: xiaojin.wy
             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)