Jane Chan created FLINK-34060: --------------------------------- Summary: Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions Key: FLINK-34060 URL: https://issues.apache.org/jira/browse/FLINK-34060 Project: Flink Issue Type: Technical Debt Components: Table SQL / Runtime Affects Versions: 1.19.0 Reporter: Jane Chan Assignee: Jane Chan
The issue is discovered when testing FLINK-31788. The Top3 function emits a tuple of (entry.getKey, entry.getKey) [UserDefinedTableAggFunctions.scala#L127|https://github.com/apache/flink/blob/907d0f32126b9f8acfc80f3f4098e71cb37f0e37/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/UserDefinedTableAggFunctions.scala#L127], which is peculiar. Meanwhile, consider getting the scala-free goal; it's time to migrate this class to the `JavaUserDefinedTableAggFunctions`, and revisit the implementation. -- This message was sent by Atlassian Jira (v8.20.10#820010)