Flink UDAF ValidationException when using HashSet/HashMap I am trying to write a Flink User Defined Aggregate Function (UDAF) for aggregation :
