#flink_minicluster — Public Fediverse posts

Apache Flink: тестирование собственного сериализатора состояния

Привет, Хабр! На связи Александр Бобряков, техлид команды МТС Аналитика. Это мой одиннадцатый пост про Apache Flink. В предыдущей части мы рассмотрели сериализацию данных во Flink, написали сериализатор, поддерживающий эволюцию схемы для Flink-состояния в операторе на основе Jackson. В этой части мы научимся писать тесты на эволюцию схемы состояния при использовании своего сериализатора. Весь разбираемый исходный код можно найти в репозитории AlexanderBobryakov/flink-spring . В master-ветке представлен итоговый проект по всей серии. Этот материал соответствует релизной ветке с названием release/10_test_JacksonStateSerializer .

https://habr.com/ru/companies/ru_mts/articles/873436/

#сериализация_данных #jacksonstateserializer #эволюция_схемы #Тестирование_Flink #Statefulоператоры #Flink_MiniCluster #RocksDB #Java_ClassLoader #автоматизация_тестирования #java