Всем привет. Это очередной выпуск обновлений в основной ветке разработки Apache Flink за прошедшую неделю с 7 по 13 сентября 2026 года.

* Подготовлено с использованием нейросетей.

📝 Обзор недели

Неделя была сосредоточена на повышении стабильности и исправлении ошибок. Основные усилия были направлены на улучшение работы коннекторов (особенно Kafka и CDC), повышение надежности CI/CD, а также на решение проблем с производительностью и утечками ресурсов в state backend ForSt. Также было проведено несколько важных голосований и обсуждений по ключевым функциям.
🚀 Новые функции и улучшения

Динамическая подписка в Fluss Pipeline Source (FLINK-40575): Добавлена поддержка динамической отписки и повторной подписки на таблицы. Теперь при удалении таблицы из результата обнаружения источник прекращает чтение без перезапуска задания, а при повторном добавлении — запускает новый жизненный цикл с учетом scan.startup.mode.

Новые функции для VARIANT (FLINK-40582): Предложены встроенные функции SCHEMA_OF_VARIANT и SCHEMA_OF_VARIANT_AGG, которые позволяют определять схему полуструктурированных данных, хранящихся в типе VARIANT, возвращая ее в виде строки с синтаксисом Flink SQL.

Улучшения для нативного S3 (FLINK-40593, FLINK-40632): Добавлена поддержка пакетного рекурсивного удаления объектов в нативном коннекторе S3. Кроме того, начато обсуждение и создана задача по снятию с него аннотации @Experimental для перевода в основной статус.

Типизация Python UDF (FLINK-40607 — FLINK-40614): Начата работа над крупной функцией — выводом типов для Python UDF (FLIP-609). Созданы задачи для реализации вывода типов для скалярных, табличных, агрегатных функций, а также для поддержки составных типов (ROW), Union и Any.

Поддержка ChangelogModes в тестовом фреймворке (FLINK-40577): Добавлена поддержка ChangelogModes в ProcessTableFunctionTestHarness, что расширяет возможности тестирования процессных табличных функций.

Улучшения для Kubernetes Operator (FLINK-40581, FLINK-40583): Исправлены примеры, которые не работали с заявленной версией Flink, и добавлена фильтрация ключей оператора и автоскейлера на оставшихся путях конфигурации во время выполнения.