You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/02 02:15:00 UTC
[jira] [Created] (FLINK-19914)
TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is
instable
Dian Fu created FLINK-19914:
-------------------------------
Summary: TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable
Key: FLINK-19914
URL: https://issues.apache.org/jira/browse/FLINK-19914
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.12.0
Reporter: Dian Fu
Fix For: 1.12.0
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=8714&view=logs&j=904e5037-64c0-5f69-f6d5-e21b89cf6484&t=39857031-7f0c-5fd5-d730-a19c5794f839
{code}
[ERROR] testEventTimeTemporalJoinChangelogUsingBeforeTime[StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.TemporalJoinITCase) Time elapsed: 0.225 s <<< FAILURE!
java.lang.AssertionError: expected:<List(+I(1,Euro,12,2020-08-15T00:01,null,null), +I(2,US Dollar,1,2020-08-15T00:02,102,2020-08-15T00:00:02), +I(3,RMB,40,2020-08-15T00:03,702,2020-08-15T00:00:04), +I(4,Euro,14,2020-08-16T00:04,118,2020-08-16T00:01), +I(5,RMB,40,2020-08-16T00:03,null,null), +I(6,RMB,40,2020-08-16T00:04,null,null), +U(2,US Dollar,18,2020-08-16T00:03,106,2020-08-16T00:02), -D(6,RMB,40,2020-08-16T00:04,null,null), -U(2,US Dollar,1,2020-08-16T00:03,106,2020-08-16T00:02))> but was:<ArrayBuffer(+I(1,Euro,12,2020-08-15T00:01,null,null), +I(2,US Dollar,1,2020-08-15T00:02,null,null), +I(3,RMB,40,2020-08-15T00:03,null,null), +I(4,Euro,14,2020-08-16T00:04,118,2020-08-16T00:01), +I(5,RMB,40,2020-08-16T00:03,null,null), +I(6,RMB,40,2020-08-16T00:04,null,null), +U(2,US Dollar,18,2020-08-16T00:03,106,2020-08-16T00:02), -D(6,RMB,40,2020-08-16T00:04,null,null), -U(2,US Dollar,1,2020-08-16T00:03,106,2020-08-16T00:02))>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:118)
at org.junit.Assert.assertEquals(Assert.java:144)
at org.apache.flink.table.planner.runtime.stream.sql.TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime(TemporalJoinITCase.scala:498)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)