Ошибка информации о типе Apache Flink для POJO, содержащего список кортежей ⇐ JAVA

[Anonymous]

Мне не удается создать класс типа POJO, содержащий тип данных, представляющий собой список кортежей. Возможно, я неправильно предоставляю информацию о типе?
Вот класс и TypeInfo:

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

@TypeInfo(NodeTestSerializer.class)
public class NodeTest implements Serializable {
public int nodeId = 1;
public boolean active = false;
public String value = "empty";
public List msgDestinationList = new ArrayList();
public HashMap messages = new HashMap();  //used in sync mode

public NodeTest() {
msgDestinationList.add(Tuple3.of(1,2,"abc"));
};
}

и я определил информацию о его типе следующим образом:

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

public class NodeTestSerializer extends TypeInfoFactory {
@Override
public TypeInformation createTypeInfo(Type t, Map

Подробнее здесь: [url]https://stackoverflow.com/questions/79184192/apache-flink-type-information-error-for-pojo-containing-list-of-tuples[/url]