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 3e348d9a487 [hotfix] Fix compilation with jdk11
3e348d9a487 is described below
commit 3e348d9a4878ed2baf3c90d6769796d1f6cf5d1a
Author: Ramin Gharib <[email protected]>
AuthorDate: Wed Jul 22 14:10:26 2026 +0200
[hotfix] Fix compilation with jdk11
---
.../planner/runtime/stream/sql/join/LateralSnapshotJoinITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/LateralSnapshotJoinITCase.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/LateralSnapshotJoinITCase.java
index 4972d4cb28c..58632e44326 100644
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/LateralSnapshotJoinITCase.java
+++
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/LateralSnapshotJoinITCase.java
@@ -153,7 +153,7 @@ public class LateralSnapshotJoinITCase extends
StreamingWithStateTestBase {
final List<Row> probes =
IntStream.range(0, probeCount)
.mapToObj(i -> Row.of("k", i,
ts(String.format("00:00:%02d", i))))
- .toList();
+ .collect(Collectors.toList());
createProbe(probes, 200L); // last probe at ~1400 ms, well past the
last post-flip update
createUpsertBuild(
Arrays.asList(