This is an automated email from the ASF dual-hosted git repository.
fhueske 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 09547cea2e2 [hotfix][table] Fix flaky TemporalJoinITCase (#28273)
09547cea2e2 is described below
commit 09547cea2e250e147b126cf3e7e225cb8230f99f
Author: Fabian Hueske <[email protected]>
AuthorDate: Thu May 28 19:26:18 2026 +0200
[hotfix][table] Fix flaky TemporalJoinITCase (#28273)
Fix was needed because FLINK-39719 modified TemporalRowTimeJoinOperator to
drop late arriving probe-side records.
TemporalJoinITCase's test data contained late records that would be dropped
(or not) depending on when sources emitted watermarks.
This fix adjusts the watermark definition of the source table such that no
late data is produced.
---
.../flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
index a733f228508..f54a488585e 100644
---
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
+++
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
@@ -212,7 +212,7 @@ class TemporalJoinITCase(state: StateBackendMode) extends
StreamingWithStateTest
| currency_no STRING,
| amount BIGINT,
| order_time TIMESTAMP(3),
- | WATERMARK FOR order_time AS order_time,
+ | WATERMARK FOR order_time AS order_time - interval
'2' DAYS,
| PRIMARY KEY (order_id) NOT ENFORCED
|) WITH (
| 'connector' = 'values',
