#flink
3 posts.
Keep Late Events from Overwriting Current State: Fluss Versioned Merge Engine
Use Apache Fluss Versioned Merge Engine to keep retries and late arrivals from replacing current state with an older event, with a runnable Flink SQL example.
apache-flussflinkstreamingdata-consistencyevent-processing
Your First Apache Fluss Run: What the Flink Quickstart Shows
Connect Apache Fluss to Flink in a local exercise environment, then use Flink SQL to examine its catalog, table models, primary-key reads, and updates.
apache-flussflinkdockerquickstartstreaming
What Is Apache Fluss? A Streaming Lakehouse Between Kafka, Flink, and Iceberg
Understand Apache Fluss by role: how it differs from Kafka, Flink, and Iceberg, and how its Log Tables, Primary Key Tables, and shared metadata connect real-time streams to a lakehouse.
apache-flusslakehousestreamingflinkarchitecture