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
commit 2b063e5d220ddce994a7954671b5671ea33fbd42 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Sat Jul 4 08:30:33 2026 +0200 [FLINK-39859][table] Remove deprecated `JavaConversions` from `FlinkStatistic` --- .../org/apache/flink/table/planner/plan/stats/FlinkStatistic.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/stats/FlinkStatistic.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/stats/FlinkStatistic.scala index 7158a8039c9..077ccfd7583 100644 --- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/stats/FlinkStatistic.scala +++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/stats/FlinkStatistic.scala @@ -30,8 +30,6 @@ import javax.annotation.Nullable import java.util -import scala.collection.JavaConversions._ - /** The class provides statistics for a [[org.apache.calcite.schema.Table]]. */ class FlinkStatistic( tableStats: TableStats, @@ -42,7 +40,7 @@ class FlinkStatistic( require(tableStats != null, "tableStats should not be null") require( - uniqueKeys == null || !uniqueKeys.exists(keys => keys == null || keys.isEmpty), + uniqueKeys == null || !uniqueKeys.stream().anyMatch(keys => keys == null || keys.isEmpty), "uniqueKeys contains invalid elements!") /**
