You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/20 08:57:00 UTC

[jira] [Closed] (FLINK-13201) Unstable sql time udf test

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

Jingsong Lee closed FLINK-13201.
--------------------------------
    Resolution: Fixed

> 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
(v8.3.4#803005)