The Seven Deadly Sins of Streaming
summary
Claim: Fluss columnar streaming storage replaces Kafka+Flink patterns by exposing streaming tables that are directly queryable and enforce schemas. Demonstrated numbers: an adopter cuts state from 1 TB → 350 GB, checkpoint time 90s → 1s, 85% lower CPU/memory, and Elcommerce user reports eliminating 100 TB of state; cluster handles 40 GB/s and 500k lookups/s. Techniques used: Apache Flink, Apache Arrow, Iceberg/Paimon/Lance formats, column pruning, partition pruning, predicate pushdown; goal is unified hot tables + lakehouse tiering with real-time joins and delta merges.
AI-written summary · about
chapters (12)
- 0:00Seven deadly streaming sins
- 3:55Streaming data pipelines today
- 9:58Kafka-centric limits
- 12:10Queryable streaming tables
- 14:57Change log challenge
- 15:39Logs vs caches for consistency
- 18:11Columnar streaming cost cuts
- 21:00Stateful join bottlenecks
- 26:15Streaming aggregations
- 27:37Streaming meets lakehouse
- 30:51Roadmap and ecosystem
- 32:56Q&A
related talks
01h 01mApache Fluss: A Streaming Storage for Real-Time Lakehouse
23mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
42mStream Processing with Apache Flink
41mStream Processor as a Database: Building Online Applications
48mUnlocking Real-time Insights: Enhancing Your Databases With Stream Processing
51mStream Processing Smackdown: Kafka Streams vs. Apache Flink
43mThe Stream Processor as a Database
43mUnified stream and batch processing with Apache Flink’s relational APIs
