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 4972d4cb28c84..58632e4432654 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 @@ void testProbesObserveProgressiveBuildVersions() { final List 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(