[ 
https://issues.apache.org/jira/browse/FLINK-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882697#comment-16882697
 ] 

Jingsong Lee commented on FLINK-13201:
--------------------------------------

Looks like there is not output row... The sql of this case has no filter, so 
it's not supposed to be.

> Unstable sql time udf test
> --------------------------
>
>                 Key: FLINK-13201
>                 URL: https://issues.apache.org/jira/browse/FLINK-13201
>             Project: Flink
>          Issue Type: Test
>          Components: Table SQL / Planner
>    Affects Versions: 1.9.0
>            Reporter: Kurt Young
>            Assignee: Jingsong Lee
>            Priority: Major
>
> org.apache.flink.table.runtime.batch.sql.CalcITCase:testTimeUDF will 
> occasionally fail when running all scala tests through IDE. 
> The output is:
> {code:java}
> java.lang.AssertionError: 
> Results do not match for query:
>   SELECT dateFunc(a), localDateFunc(a), dateFunc(b), localDateFunc(b), 
> timeFunc(c), localTimeFunc(c), timeFunc(d), localTimeFunc(d), 
> timestampFunc(e), datetimeFunc(e), timestampFunc(f), datetimeFunc(f) FROM 
> MyTable
> Results
>  == Correct Result - 1 ==                                                     
>                                                                               
>            == Actual Result - 1 ==
> !1984-07-12,1984-07-12,1984-07-12,1984-07-12,08:03:09,08:03:09,08:03:09,08:03:09,2019-09-19
>  08:03:09.0,2019-09-19T08:03:09,2019-09-19 08:03:09.0,2019-09-19T08:03:09   
> 1984-07-11,1984-07-12,1984-07-11,1984-07-12,00:03:09,08:03:09,08:03:09,16:03:09,2019-09-19
>  00:03:09.0,2019-09-19T08:03:09,2019-09-19 08:03:09.0,2019-09-19T16:03:09
>         
> Plan:
>   == Abstract Syntax Tree ==
> LogicalProject(EXPR$0=[dateFunc($0)], EXPR$1=[localDateFunc($0)], 
> EXPR$2=[dateFunc($1)], EXPR$3=[localDateFunc($1)], EXPR$4=[timeFunc($2)], 
> EXPR$5=[localTimeFunc($2)], EXPR$6=[timeFunc($3)], 
> EXPR$7=[localTimeFunc($3)], EXPR$8=[timestampFunc($4)], 
> EXPR$9=[datetimeFunc($4)], EXPR$10=[timestampFunc($5)], 
> EXPR$11=[datetimeFunc($5)])
> +- LogicalTableScan(table=[[default_catalog, default_database, MyTable]])
> == Optimized Logical Plan ==
> Calc(select=[dateFunc(a) AS EXPR$0, localDateFunc(a) AS EXPR$1, dateFunc(b) 
> AS EXPR$2, localDateFunc(b) AS EXPR$3, timeFunc(c) AS EXPR$4, 
> localTimeFunc(c) AS EXPR$5, timeFunc(d) AS EXPR$6, localTimeFunc(d) AS 
> EXPR$7, timestampFunc(e) AS EXPR$8, datetimeFunc(e) AS EXPR$9, 
> timestampFunc(f) AS EXPR$10, datetimeFunc(f) AS EXPR$11])
> +- BoundedStreamScan(table=[[default_catalog, default_database, MyTable]], 
> fields=[a, b, c, d, e, f])
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to