您好，
在使用flink+hive进行离线数据挖掘中，需要使用到TableAggregationFunction的功能，但在idea调试过程中出现如下问题，请老师帮忙分析一下，谢谢。
1、目前flink版本为1.12.0，在参考https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/functions/udfs.html#aggregate-functions开发时，PLAN阶段出现错误，具体操作信息在附件《错误信息.txt》中。
2、数据内容项如下：
3、代码在附件中。
4、代码的逻辑：根据address分组，获取分组中organ_id最大的一行数据。wanglongl...@wondersgroup.com
