You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/08 15:42:00 UTC
[jira] [Resolved] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output
[ https://issues.apache.org/jira/browse/FLINK-40950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sergey Nuyanzin resolved FLINK-40950.
-------------------------------------
Fix Version/s: 2.4.0
Assignee: Sergey Nuyanzin
Resolution: Fixed
Merged as [b68f22c91297ba5949780296a7f4e8ff2e484c53|https://github.com/apache/flink/commit/b68f22c91297ba5949780296a7f4e8ff2e484c53]
> 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
> Assignee: Sergey Nuyanzin
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 2.4.0
>
>
> 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)