In this JIRA. I will do the following tasks for Flink 1.3.0 RC01 Release.
- Check that the JAVA and SCALA logical plans are consistent.
- Check that the SQL and Table API logical plans are consistent.
- Check that UDF, UDTF, and UDAF are working properly in group-windows and over-windows.
- Check that all built-in Agg on Batch and Stream are working properly.
- Let types such as Timestamp, BigDecimal or Pojo flow through UDF. UDTF, UDAF (input and output types)
I'll created some sub-task if i find some bugs when I do the task above.