Martijn Visser created FLINK-40950:
--------------------------------------
Summary: EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin
fails with unexpected output
Key: FLINK-40950
URL: https://issues.apache.org/jira/browse/FLINK-40950
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 2.4.0
Reporter: Martijn Visser
All builds on master are failing
{code:java}
Oct 07 19:44:19 19:44:19.932 [ERROR] Failures:
Oct 07 19:44:19 19:44:19.932 [ERROR]
EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin:205->verify:282
Expected:
Oct 07 19:44:19 Calc(select=[a, b])
Oct 07 19:44:19 +- IntervalJoin(joinType=[LeftOuterJoin],
windowBounds=[isRowTime=true, leftLowerBound=-10000, leftUpperBound=3600000,
leftTimeIndex=1, rightTimeIndex=2], where=[((a = a0) AND (rowtime >= (rowtime0
- 10000:INTERVAL SECOND)) AND (rowtime <= (rowtime0 + 3600000:INTERVAL
HOUR)))], select=[a, rowtime, a0, b, rowtime0], earlyFireDelay=[5000],
earlyFireTimeMode=[PROCTIME])
Oct 07 19:44:19 :- Exchange(distribution=[hash[a]])
Oct 07 19:44:19 : +- WatermarkAssigner(rowtime=[rowtime],
watermark=[rowtime])
Oct 07 19:44:19 : +- TableSourceScan(table=[[default_catalog,
default_database, MyTable, project=[a, rowtime], metadata=[]]], fields=[a,
rowtime])
Oct 07 19:44:19 +- Exchange(distribution=[hash[a]])
Oct 07 19:44:19 +- WatermarkAssigner(rowtime=[rowtime],
watermark=[rowtime])
Oct 07 19:44:19 +- TableSourceScan(table=[[default_catalog,
default_database, MyTable2, project=[a, b, rowtime], metadata=[]]], fields=[a,
b, rowtime])
Oct 07 19:44:19 but was:
Oct 07 19:44:19 Calc(select=[a, b])
Oct 07 19:44:19 +- IntervalJoin(joinType=[LeftOuterJoin],
windowBounds=[isRowTime=true, leftLowerBound=-10000, leftUpperBound=3600000,
leftTimeIndex=1, rightTimeIndex=2], where=[((a = a0) AND (rowtime >= (rowtime0
- 10000:INTERVAL SECOND)) AND (rowtime <= (rowtime0 + 3600000:INTERVAL
HOUR)))], select=[a, rowtime, a0, b, rowtime0], earlyFireDelay=[5000],
earlyFireTimeMode=[PROCTIME])
Oct 07 19:44:19 :- Exchange(distribution=[hash[a]])
Oct 07 19:44:19 : +- WatermarkAssigner(rowtime=[rowtime],
watermark=[rowtime])
Oct 07 19:44:19 : +- TableSourceScan(table=[[default_catalog,
default_database, MyTable, project=[a, rowtime]]], fields=[a, rowtime])
Oct 07 19:44:19 +- Exchange(distribution=[hash[a]])
Oct 07 19:44:19 +- WatermarkAssigner(rowtime=[rowtime],
watermark=[rowtime])
Oct 07 19:44:19 +- TableSourceScan(table=[[default_catalog,
default_database, MyTable2, project=[a, b, rowtime]]], fields=[a, b, rowtime])
Oct 07 19:44:19
Oct 07 19:44:19 19:44:19.932 [INFO]
Oct 07 19:44:19 19:44:19.932 [ERROR] Tests run: 11739, Failures: 1, Errors: 0,
Skipped: 43
{code}
Examples:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=79921&view=logs&j=086353db-23b2-5446-2315-18e660618ef2&t=87e39f83-bb6a-550a-8a36-1098f71ef110&l=9985
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=79917&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=019d96ac-af5c-5c6d-106d-b67f63cc6e96&l=9972
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=79919&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=019d96ac-af5c-5c6d-106d-b67f63cc6e96&l=9973
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
