address comments

lincoln-lil · Aug 6, 2024 · 746b82f · 746b82f
1 parent a9cddd1
commit 746b82f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/OverAggregateUtil.scala b/...-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)