Всем привет!

К сожалению, из-за нагрузки на работе я не смогу сегодня провести эфир, а объём материала на повестке в 5-6 главе однозначно выходит за рамки 2 часов

Так как я не готов далее двигать эфиры по Flink, впервые в качестве исключения запишу свои рассуждения на тему главы в асинхронном формате и выложу после выходных:
🔶 Вернёмся к checkpointing и поговорим про savepointing, который неразрывно связан с вопросами работы с состоянием Flink. Хотя изначально материал относился к 3 главе, к сожалению, он не влез в тайминги. Тем не менее, без него мне кажется неправильным закапываться в главу про state
🔶 Посмотрим на state во Flink: готовьтесь к моему субъективному бурчанию на тему некоторой неочевидности API в духе использования Java Serialization, разного подхода к определению list и отдельных значений для state и т. д.
🔶 Пройдёмся от выбора хранилища состояния к реализации к описанию кастомных Source и Sink + queryable state. Пробежимся, какие коннекторы Flink предоставляет из коробки

P.S.: следующая книга будет более разгрузочной, наподобие «Современной программной инженерии». Заодно, с учётом моего погружения в тему подготовка эфиров будет качественно лучше