一切正常,但聚合函数,当我使用它们时,它得到以下异常: aggregating on field positions is only possible on tuple data types 然后,我将我的类更改为实现Tuple4 (因为我有4个字段),但是当我想要收集结果时,将获得AvroTypeException未知类型: T0 以下是我的数据和作业类别: public class Nation{
nation.aggregate(Aggregations.SUM,0);
JobExecutionResult re
我想做一些DataSet转换,但是Flink中的最大列Tuple是Tuple25,包含25列。java.lang.IllegalArgumentException: The tuple type exceedsthe maximum supported arity
如果我不扩展Tuple类,我将这些行成功地映射为元组,但是当我