Всем привет!

Мы наконец-то вернулись к регулярному графику с еженедельными выпусками и представляем вашему вниманию обсуждение 3-4 главы!

В рамках выпуска:
🔶 Детальнее прошлись по компонентам Flink-кластера — рассмотрели, за счёт чего можно использовать различные окружения (Kubernates, On-Premise, YARN и т. д.)
🔶 Обсудили, как Flink обеспечивает отказоустойчивость и восстановление после ошибок отдельных компонентов
🔶 Посмотрели на коммуникацию между TaskManager’ами (worker’ами) и поговорили, почему важно корректно настраивать размеры сетевых буферов
🔶 На примере из книги рассмотрели пошаговое обновление watermark
🔶 Заглянули в локально установленный on-premise Flink с его конфигурацией, увидели пример запуска простейшей задачи и её визуализации в UI

Ставьте 🔥, если понравился новый выпуск! Завтра в 21:00 по мск опубликуем информацию про следующую встречу 25.10.2025 с обсуждением API Flink (5-6 главы)

Источники:
- Гайд по установке
- Примеры простых программ в официальном репозитории Flink

#in_the_flow #flink #streaming