You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2026/10/07 22:19:50 UTC
(flink) branch master updated: [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin`
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b68f22c9129 [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin`
b68f22c9129 is described below
commit b68f22c91297ba5949780296a7f4e8ff2e484c53
Author: Sergey Nuyanzin <sn...@gmail.com>
AuthorDate: Thu Oct 8 00:19:43 2026 +0200
[hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin`
---
.../flink/table/planner/plan/hints/stream/EarlyFireJoinHintTest.xml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/stream/EarlyFireJoinHintTest.xml b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/stream/EarlyFireJoinHintTest.xml
index cd6635a1f6d..7991798b353 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/stream/EarlyFireJoinHintTest.xml
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/stream/EarlyFireJoinHintTest.xml
@@ -269,10 +269,10 @@ Calc(select=[a, b])
+- 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])
:- Exchange(distribution=[hash[a]])
: +- WatermarkAssigner(rowtime=[rowtime], watermark=[rowtime])
- : +- TableSourceScan(table=[[default_catalog, default_database, MyTable, project=[a, rowtime], metadata=[]]], fields=[a, rowtime])
+ : +- TableSourceScan(table=[[default_catalog, default_database, MyTable, project=[a, rowtime]]], fields=[a, rowtime])
+- Exchange(distribution=[hash[a]])
+- WatermarkAssigner(rowtime=[rowtime], watermark=[rowtime])
- +- TableSourceScan(table=[[default_catalog, default_database, MyTable2, project=[a, b, rowtime], metadata=[]]], fields=[a, b, rowtime])
+ +- TableSourceScan(table=[[default_catalog, default_database, MyTable2, project=[a, b, rowtime]]], fields=[a, b, rowtime])
]]>
</Resource>
</TestCase>