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 83506f9106a7ee9fab53004b2279f71cf9fa6fa2 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Sat Jul 4 12:30:14 2026 +0200 [FLINK-40062][table] Replace deprecated `JavaConversions` with `JavaConverters` --- .../apache/flink/table/planner/plan/utils/AggFunctionFactory.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala index 37ba914bacd..a043560cd68 100644 --- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala +++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala @@ -37,7 +37,7 @@ import org.apache.calcite.sql.fun._ import java.util -import scala.collection.JavaConversions._ +import scala.collection.JavaConverters._ /** * Factory for creating runtime implementation for internal aggregate functions that are declared as @@ -62,7 +62,7 @@ class AggFunctionFactory( /** The entry point to create an aggregate function from the given [[AggregateCall]]. */ def createAggFunction(call: AggregateCall, index: Int): UserDefinedFunction = { - val argTypes: Array[LogicalType] = call.getArgList + val argTypes: Array[LogicalType] = call.getArgList.asScala .map(inputRowType.getChildren.get(_)) .toArray
