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 5004b5bee5e [hotfix][table] Fix compilation with jdk11
5004b5bee5e is described below
commit 5004b5bee5e7ee4e6ce931ea61b98006addbf6ea
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Wed Jul 15 14:59:56 2026 +0200
[hotfix][table] Fix compilation with jdk11
---
.../snapshot/LateralSnapshotJoinOperatorTest.java | 20 ++++++++++++--------
1 file changed, 12 insertions(+), 8 deletions(-)
diff --git
a/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/snapshot/LateralSnapshotJoinOperatorTest.java
b/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/snapshot/LateralSnapshotJoinOperatorTest.java
index fdd4df88c04..1fb82fad800 100644
---
a/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/snapshot/LateralSnapshotJoinOperatorTest.java
+++
b/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/snapshot/LateralSnapshotJoinOperatorTest.java
@@ -57,6 +57,7 @@ import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.stream.Collectors;
import java.util.stream.Stream;
import static
org.apache.flink.table.runtime.operators.join.snapshot.LateralSnapshotJoinOperator.BUILD_CHANGE_BUFFER_STATE_NAME;
@@ -491,7 +492,7 @@ class LateralSnapshotJoinOperatorTest {
List<Long> emittedProbeIds =
h.getOutput().stream()
.map(o -> ((RowData) ((StreamRecord<?>)
o).getValue()).getLong(0))
- .toList();
+ .collect(Collectors.toList());
assertThat(emittedProbeIds).containsExactly(1L, 2L, 3L, 4L, 5L);
JOINED_ASSERTOR.shouldEmitAll(
h,
@@ -536,7 +537,7 @@ class LateralSnapshotJoinOperatorTest {
List<Long> emittedProbeIds =
h.getOutput().stream()
.map(o -> ((RowData) ((StreamRecord<?>)
o).getValue()).getLong(0))
- .toList();
+ .collect(Collectors.toList());
assertThat(emittedProbeIds).containsExactly(1L, 2L);
JOINED_ASSERTOR.shouldEmitAll(
h, row(1L, "k1", "p1", "k1", "v1", 1L), row(2L, "k1",
"p2", "k1", "v1", 1L));
@@ -1518,7 +1519,7 @@ class LateralSnapshotJoinOperatorTest {
List<Long> emittedProbeIds =
h.getOutput().stream()
.map(o -> ((RowData) ((StreamRecord<?>)
o).getValue()).getLong(0))
- .toList();
+ .collect(Collectors.toList());
assertThat(emittedProbeIds).containsExactly(1L, 2L, 3L);
JOINED_ASSERTOR.shouldEmitAll(
h,
@@ -1739,7 +1740,7 @@ class LateralSnapshotJoinOperatorTest {
List<Long> emittedIds =
h.getOutput().stream()
.map(o -> ((RowData) ((StreamRecord<?>)
o).getValue()).getLong(0))
- .toList();
+ .collect(Collectors.toList());
assertThat(emittedIds).containsExactly(1L, 2L);
JOINED_ASSERTOR.shouldEmitAll(
h, row(1L, "k1", "p1", "k1", "v1", 1L), row(2L, "k1",
"p2", "k1", "v1", 1L));
@@ -2048,7 +2049,7 @@ class LateralSnapshotJoinOperatorTest {
.getKeys(BUILD_TABLE_STATE_NAME, VoidNamespace.INSTANCE)
.map(r -> ((BinaryRowData) r).getString(0).toString())
.sorted()
- .toList();
+ .collect(Collectors.toList());
}
private static List<String> probeBufferKeys(
@@ -2059,7 +2060,7 @@ class LateralSnapshotJoinOperatorTest {
.getKeys(PROBE_BUFFER_STATE_NAME, VoidNamespace.INSTANCE)
.map(r -> ((BinaryRowData) r).getString(0).toString())
.sorted()
- .toList();
+ .collect(Collectors.toList());
}
/**
@@ -2156,7 +2157,10 @@ class LateralSnapshotJoinOperatorTest {
}
private static List<Watermark>
extractWatermarks(ConcurrentLinkedQueue<Object> output) {
- return output.stream().filter(o -> o instanceof Watermark).map(w ->
(Watermark) w).toList();
+ return output.stream()
+ .filter(o -> o instanceof Watermark)
+ .map(w -> (Watermark) w)
+ .collect(Collectors.toList());
}
/**
@@ -2180,6 +2184,6 @@ class LateralSnapshotJoinOperatorTest {
return output.stream()
.filter(o -> o instanceof WatermarkStatus)
.map(w -> (WatermarkStatus) w)
- .toList();
+ .collect(Collectors.toList());
}
}
