Всем привет! Мы наконец-то вернулись к регулярному графику с еженедельными выпусками и представляем вашему вниманию обсуждение 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