Новое Распределяем каналы MAX по категориям и территориям. Читать новость
Открытый канал ID 76754487467480

Apache Flink

Канал для обсуждения и публикации новостей по продукту Apache Flink

Россия
Открыть в MAX

Публикации за период

По реакциям

Поиск и вся лента — после бесплатной регистрации. Свои даты — по подписке; владелец канала видит их бесплатно. Сортировка по реакциям — по подписке. Зарегистрироваться

Загрузка…

🔒 Безопасность

Уязвимости в 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 Kubernetes Operator. Переход был мотивирован сложностью поддержки собственного решения и проблемами с автоскейлингом. Официальный оператор предоставил такие преимущества, как обновления с сохранением состояния (last-state upgrades), автомасштабирование на месте и автоматическая настройка ресурсов.

Ключевые изменения и исправления: В списке рассылки активно создавались JIRA-тикеты для исправления ошибок и улучшений. Среди них: проблемы с toString() для типа VARIANT, ошибки в INSERT с колонками типа VARIANT и BITMAP, проблемы с производительностью MATCH_RECOGNIZE, а также ошибки в стриминговых outer join для upsert-потоков.

Конференция Current 2026: Анонсировано крупнейшее событие в области потоковой передачи данных, которое пройдет 4-5 ноября 2026 года в Сан-Франциско. В центре внимания будут Apache Kafka, Apache Flink и Apache Iceberg.

На этом все. Следующий выпуск ожидайте в начале следующей недели.
Просмотры: 5
Перейти в пост Открыть в MAX Сообщить о неточности
Всем привет. Это очередной выпуск сводки обновлений в основной ветке разработки 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-сервер.
Просмотры: 2
Перейти в пост Открыть в MAX Сообщить о неточности
ВКонтакте Телеграм Одноклассники
Избранное в datool.ru

Следите за каналом в личном кабинете

Зарегистрируйтесь в datool.ru, чтобы добавить канал «Apache Flink» в избранное и отслеживать его показатели.

Зарегистрироваться
Для владельцев каналов

Подтвердите свой канал

Войдите или зарегистрируйтесь в datool.ru, затем добавьте нашего бота в канал по инструкции в личном кабинете. После проверки владения замок исчезнет и вам станет доступно управление каналом.

Войти или зарегистрироваться

Сообщить о неточности

Опишите, что нужно исправить. Если есть источник, добавьте ссылку.

Вы покидаете datool.ru

Ссылка ведёт на внешний сайт. datool.ru не отвечает за его содержимое — проверьте адрес, прежде чем вводить пароли или платёжные данные.

Переход через 10 с

Перейти