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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
Kurt Young created FLINK-13201:
----------------------------------

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


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.3#76005)