Вышел Flink 2.3.0
На мой взгляд, самое важное изменение — обновление SinkUpsertMaterializer.
SinkUpsertMaterializer может автоматически добавляться планировщиком Flink Table API, когда возникает несоответствие между upsert-операциями и первичным ключом (а такое происходит очень часто).
Теперь в Flink наконец появилась оптимизация, которая позволяет очищать состояние (state) на основе watermarks. Раньше состояние SinkUpsertMaterializer только росло и никогда не освобождалось.
https://flink.apache.org/2026/06/25/apache-flink-2.3.0-release-announcement/
@tldr_data
Post #115
141