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 019c6249ddf [FLINK-39948][planner] Fix compile issue in jdk11 for 
table-planner
019c6249ddf is described below

commit 019c6249ddfcd4c02ba64253470022df0085dbac
Author: reswqa <[email protected]>
AuthorDate: Wed Jun 17 17:34:59 2026 +0800

    [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner
---
 .../plan/metadata/FlinkRelMdModifiedMonotonicityTest.scala        | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicityTest.scala
 
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicityTest.scala
index 586c0daa92c..3cc1813bc32 100644
--- 
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicityTest.scala
+++ 
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicityTest.scala
@@ -21,7 +21,7 @@ import 
org.apache.flink.table.planner.plan.`trait`.RelModifiedMonotonicity
 import org.apache.flink.table.planner.plan.nodes.logical.{FlinkLogicalRank, 
FlinkLogicalTableAggregate}
 import org.apache.flink.table.runtime.operators.rank.{ConstantRankRange, 
RankType}
 
-import org.apache.calcite.rel.`type`.{RelDataTypeFieldImpl, RelRecordType}
+import org.apache.calcite.rel.`type`.{RelDataTypeField, RelDataTypeFieldImpl, 
RelRecordType}
 import org.apache.calcite.rel.RelCollations
 import org.apache.calcite.rel.core.JoinRelType
 import org.apache.calcite.rel.hint.RelHint
@@ -35,6 +35,7 @@ import org.junit.jupiter.api.Assertions._
 import org.junit.jupiter.api.Test
 
 import java.util
+import java.util.stream.Collectors
 
 import scala.collection.JavaConverters.seqAsJavaListConverter
 import scala.language.postfixOps
@@ -62,7 +63,10 @@ class FlinkRelMdModifiedMonotonicityTest extends 
FlinkRelMdHandlerTestBase {
     // project `age` field and corresponding output type
     val projection = java.util.List.of[RexInputRef](relBuilder.field("age"))
     val ageFieldType =
-      inputAgg.getRowType.getFieldList.stream().filter(x => 
x.getName.equals("age")).toList
+      inputAgg.getRowType.getFieldList
+        .stream()
+        .filter(x => x.getName.equals("age"))
+        .collect(Collectors.toList[RelDataTypeField]())
     val outputType = new RelRecordType(ageFieldType)
 
     // select age from (select id, age, count() from student by id, age) where 
...

Reply via email to