(flink) branch master updated: [hotfix] Fix compiliation for java 11 (#28225)

[fhueske]

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 3ac4da3bb86 [hotfix] Fix compiliation for java 11 (#28225)
3ac4da3bb86 is described below

commit 3ac4da3bb860ce1ed1c627fd703aaa1c1d4e96d1
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Fri May 22 09:18:03 2026 +0200

    [hotfix] Fix compiliation for java 11 (#28225)
---
 .../flink/table/runtime/functions/ptf/ToChangelogFunction.java       | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/ptf/ToChangelogFunction.java
 
b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/ptf/ToChangelogFunction.java
index cf0547dbab0..0b6c6ca55b8 100644
--- 
a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/ptf/ToChangelogFunction.java
+++ 
b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/ptf/ToChangelogFunction.java
@@ -41,6 +41,7 @@ import javax.annotation.Nullable;
 import java.util.EnumMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * Runtime implementation of {@link BuiltInFunctionDefinitions#TO_CHANGELOG}.
@@ -131,7 +132,9 @@ public class ToChangelogFunction extends 
BuiltInProcessTableFunction<RowData> {
             return;
         }
         final List<RowKind> unsupported =
-                mapping.keySet().stream().filter(kind -> 
!inputMode.contains(kind)).toList();
+                mapping.keySet().stream()
+                        .filter(kind -> !inputMode.contains(kind))
+                        .collect(Collectors.toList());
         if (!unsupported.isEmpty()) {
             throw new ValidationException(
                     String.format(