Apache Flink

🔒 Безопасность Уязвимости в IBM Operator for Apache Flink: Опубликован бюллетень безопасности, описывающий 8 уязвимостей. Обновление зависимостей: Для устранения уязвимостей в jackson-databind (CVE-2026-54512 — 54518) предлагается обновить jackson-bom до версии 2.22.2. Также отслеживаются уязвимости в flink-kubernetes-operator (например, CVE-2026-59949) с рекомендациями по обновлению. 🛠️ Инфраструктура и события Переход Lyft на Apache Flink Kubernetes Operator: Крупная технологическая компания Lyft опубликовала отчет о миграции сотен своих production-заданий Flink с собственн…

Всем привет. Это очередной выпуск сводки обновлений в основной ветке разработки Apache Flink а так же немного важной информации произошедшей за прошедшую неделю с 28 сентября по 4 октября 2026 года. * Подготовлено с использованием нейросетей 📝 Ключевые инициативы и FLIP FLIP-612: Native XML Functions для Flink SQL: Голосование по этому FLIP было успешно завершено. Предложение единогласно одобрено (7 голосов "за", 4 из которых — обязывающие). Инициатива добавляет встроенные функции PARSE_XML и TRY_PARSE_XML для преобразования XML-строк в формат VARIANT, а также XML_STRING для обратного п…

💬 Обсуждения и активность в комьюнити Помимо основной рассылки, жизнь в сообществе кипела и в других местах: Конференции и митапы: Flink Forward Asia 2026: Это крупнейшая конференция, организованная Alibaba Cloud, прошла в Шэньчжэне 26-27 июня 2026 года. Главной темой стала эволюция Flink от Cloud Native к AI Native, с акцентом на Agentic Streaming — использование потоковой обработки для приложений на базе AI-агентов. FLUSS FORWARD: 22 сентября 2026 года в Лондоне прошло однодневное мероприятие, посвященное Apache Fluss (Incubating) — потоковой системе хранения, тесно…

🔧 Активность в коммитах и релизах В период с 14 по 27 сентября в основной ветке (master) было зафиксировано 47 коммитов. Основные усилия были сосредоточены на: Улучшении восстановления после сбоев: Работа над стабильностью рантайма и механизмов восстановления. Планировании SQL: Изменения в логике планировщика для корректной обработки changelog-потоков. Очистке бэкенда состояний: Работа по оптимизации и очистке кода, связанного с хранением состояний. Также в этот период состоялся релиз Apache Flink Kubernetes Operator 1.16.1. Это был патч-релиз, выпущенный для исправления серь…

🔧 Активность в коммитах и релизах В период с 14 по 27 сентября в основной ветке (master) было зафиксировано 47 коммитов. Основные усилия были сосредоточены на: Улучшении восстановления после сбоев: Работа над стабильностью рантайма и механизмов восстановления. Планировании SQL: Изменения в логике планировщика для корректной обработки changelog-потоков. Очистке бэкенда состояний: Работа по оптимизации и очистке кода, связанного с хранением состояний. Также в этот период состоялся релиз Apache Flink Kubernetes Operator 1.16.1. Это был патч-релиз, выпущенный для исправления серь…

Всем привет это очередной выпуски изменений в основной ветке разработки Apache Flink, а так же сопутствующих активностях по этому продукту. НА прошлой неделе выпуска не было поэтому сегодняшний выпуск включает активности за 2 прошедшие недели: с 14 по 27 сентября 2026 года. * Подготовлено с использованием нейросетей 🚀 Подготовка к релизу Flink 2.4 Основным вектором развития была подготовка к релизу Flink 2.4. Обсуждение таймлайна началось ещё в конце августа. В качестве ключевой даты было предложено 30 сентября для заморозки функций (feature freeze), а сам релиз намечен на конец октября. О…

💬 Обсуждения и решения Голосование по FLIP-597 (Hadoop-less Flink filesystems): Принято решение о принятии FLIP-597, что открывает путь к созданию файловых систем Flink без зависимости от Hadoop. Голосование по FLIP-609 (Type Inference for Python UDF): FLIP-609 был принят, что означает, что в будущем вывод типов для Python UDF станет реальностью, что значительно улучшит опыт разработки на Python. Обсуждение удаления устаревших конфигураций: Начато обсуждение по систематическому удалению давно устаревших ключей конфигурации в серии Flink 2.x, что должно упростить поддержку и пон…

🐛 Исправления ошибок Ошибки в Kafka Connect (FLINK-40585, FLINK-40586, FLINK-40604 и др.): Исправлен ряд проблем, включая периодические сбои KafkaSinkITCase.rescaleListing, вызванные фехтованием восстановленных транзакций, и ошибку, при которой DynamicKafkaSourceEnumerator повторно отправлял события завершения уже завершенным читателям, что приводило к сбоям задач. Проблемы с S3 (FLINK-40576, FLINK-40595): Удалена устаревшая и уязвимая транзитивная зависимость alluxio из flink-s3-fs-presto. В нативном S3-коннекторе исправлена ошибка, из-за которой всегда прерывались многочастные заг…

Всем привет. Это очередной выпуск обновлений в основной ветке разработки Apache Flink за прошедшую неделю с 7 по 13 сентября 2026 года. * Подготовлено с использованием нейросетей. 📝 Обзор недели Неделя была сосредоточена на повышении стабильности и исправлении ошибок. Основные усилия были направлены на улучшение работы коннекторов (особенно Kafka и CDC), повышение надежности CI/CD, а также на решение проблем с производительностью и утечками ресурсов в state backend ForSt. Также было проведено несколько важных голосований и обсуждений по ключевым функциям. 🚀 Новые функции и улучшения Д…

💎 Заключение Прошедшая неделя продемонстрировала высокую активность сообщества Apache Flink. Ключевые направления включают: Подготовку к релизу Flink 2.4 и формирование команды релиз-менеджеров. Продвижение стратегических инициатив, таких как отказ от Hadoop (FLIP-597) и улучшение Python API (FLIP-609). Повышение совместимости и производительности за счет добавления нативной поддержки UUID (FLIP-604) и исправления критических ошибок в механизме checkpointing. На этом все. Следующий выпуск ожидайте в начале следующей недели.