Всем привет. Это очередной выпуск сводки обновлений в основной ветке разработки 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 для обратного преобразования.

FLIP-614: DEDUPLICATE_KEEP_FIRST PTF: Продолжается обсуждение Process Table Function (PTF), призванной упростить одну из самых частых операций в Flink SQL — дедупликацию. Функция предложит два режима: без использования watermark (первая запись по ключу) и с использованием event-time (запись с наименьшим временем события). Ожидается, что голосование по FLIP начнется в ближайшее время.

FLIP-615: Snapshot Splitters для JDBC: Идет обсуждение нового механизма для параллельного и согласованного чтения данных из JDBC-источников. Предлагаются два типа сплиттеров: для чтения одной таблицы и для чтения целой базы данных. В ходе обсуждения были подняты вопросы о производительности при составных первичных ключах и о возможности повторного использования абстракции ConnectionProvider из другого FLIP.

Тип данных GEOGRAPHY: Дискуссия о добавлении встроенного геопространственного типа в Flink SQL продолжается. Ключевой вопрос — стоит ли сначала реализовать тип в Apache Calcite, чтобы избежать потенциальных проблем в будущем, или можно двигаться вперед с нативной реализацией в Flink.

Руководство по изменениям в PTF: Начато обсуждение общих принципов внесения изменений в уже одобренные Process Table Functions. Предлагается использовать обычное ревью для исправлений без изменения API и открывать обсуждение в списке рассылки для обратно совместимых, но значимых изменений.

🚀 Выпуск версий и обновления

Flink 2.4: Подтверждены ключевые даты релиза. Завершение разработки (Feature Freeze) запланировано на 20 октября 2026 года, а сам релиз — на 20 ноября 2026 года. Третья встреча менеджеров по выпуску (Release Manager Sync) назначена на 9 октября.

Flink Kubernetes Operator 1.16.1: Был выпущен экстренный патч-релиз для исправления критической ошибки в функции наблюдаемой конфигурации времени выполнения (runtime config observe feature), которая вызывала проблемы при развертывании и перезапуске здоровых приложений. Релиз 1.16.0, вышедший ранее, получил реструктурированную документацию и новый режим BALANCED для выравнивания параллелизма автоскейлера.

Flink CDC 3.7.0: Начато голосование за первый релиз-кандидат (RC1) версии 3.7.0. В него войдут такие улучшения, как поддержка Fluss CDC (FLINK-39722) и освобождение метаданных снапшот-сплитов после завершения снапшота для снижения нагрузки на память JobManager (FLINK-40697).

Коннектор AWS 6.1.0: Предложен к выпуску новый релиз коннектора для AWS. Основной мотивацией является добавление конфигурации для интервала между вызовами getRecords, что было явным запросом от пользователей.

Confluent Platform 8.3: Выпущен релиз платформы, который включает Confluent Platform for Apache Flink 2.4.0, предлагая упрощенное управление Flink SQL через встроенный UI и MCP-сервер.