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
...