Можно ли десериализовать объект Flink Row через Kryo? - PullRequest
0 голосов
/ 06 июня 2019

Поскольку Row не имеет конструктора без аргументов в Java, Kryo жалуется при попытке десериализации из байта [] в Row с ошибкой «отсутствует конструктор без аргументов». Я намереваюсь сериализовать объект Row в byte [], записать в тему kafka, а затем использовать из другого потока и десериализовать byte [] обратно в Row. Какие-либо предложения? Благодаря.

...