Предоставьте информацию о типе Flink для сериализации объекта аккумулятора без Kryo. ⇐ JAVA

[Anonymous]

У меня есть специальная AggregateFunction с такой сигнатурой:

Код: Выделить всё

public class CustomAggregateFunction
implements AggregateFunction { code...}

Мой AggregationAccumulator — это простой объект, содержащий несколько карт с аннотацией Lombok @Data

Код: Выделить всё

  @Data
public static class AggregationAccumulator {
private Map customMap = new HashMap();
}

Однако Флинк сообщает, что 13:18:50,091 INFO org.apache.flink.api.java.typeutils.TypeExtractor [] — Field AggregationAccumulator#customMap будет обрабатываться как GenericType. Пожалуйста, прочитайте документацию Flink «Типы данных и сериализация», чтобы узнать подробности о влиянии на производительность и эволюцию схемы.
Как я могу предоставить информацию о типе, чтобы она не ты не используешь Крио?

Подробнее здесь: https://stackoverflow.com/questions/792 ... thout-kryo