diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/OverAggregateUtil.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/OverAggregateUtil.scala
index 7d67b380e9d1c..b054d2af8866b 100644
--- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/OverAggregateUtil.scala
+++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/OverAggregateUtil.scala
@@ -231,7 +231,7 @@ object OverAggregateUtil {
       aggCalls: Seq[AggregateCall]): RelDataType = {
 
     val inputNameList = inputType.getFieldNames
-    val inputTypeList = inputType.getFieldList.asScala.map(field => field.getType)
+    val inputTypeList = inputType.getFieldList.asScala.map(_.getType)
 
     // we should avoid duplicated names with input column names
     val aggNames = RowTypeUtils.getUniqueName(aggCalls.map(_.getName), inputNameList)