scale.bythebay.io: Stephan Ewen, Apache Flink and the Next Wave of Stream Processing Applications
summary
Apache Flink is presented as a runtime for stateful stream computations that combines event-time watermarks, large in-process state and exactly-once guarantees via coordinated distributed snapshots. Examples include Alibaba powering realtime shopping and Uber/Netflix streaming analytics; a social-feed built entirely on streams shows full app logic and views computed in Flink. Demo upgrades carry forward live state by snapshot and forks a prior snapshot to reprocess historical data; the redeploy and backfill both run successfully in seconds on an AWS test cluster.
AI-written summary · about
chapters (17)
- 0:00Intro
- 0:24data Artisans
- 3:37Batch Processing
- 4:31Apache Flink in a Nutshell
- 12:10Hardened at scale
- 15:36Write log and tables
- 22:26Distributed Memory Image
- 23:17Stateful Event & Stream Processing
- 24:31What users built on checkpoints...
- 27:39Performance
- 28:35Scaling a Service
- 29:02Rolling out a new Service
- 29:58Time: Different Notions of Time
- 30:54Event Time and Proc. Time Clocks
- 31:18Time: Watermarks in Parallel
- 34:34What changes faster? Data or Query?
- 36:21Blending Analytics & Business Logic
related talks
38mApache Flink: A Very Quick Guide
42mStream Processing beyond Streaming Data
35mApache Flink 2.0: Unified Enterprise Data Processing System and Beyond
25mData: Moving with the flow
41mBeyond the Hype: When Apache Flink Solves Real Problems
42mApache Flink deep-dive #bbuzz
43mA Data Streaming Architecture with Apache Flink #bbuzz
34mBeaming Flink to the Cloud @ Netflix
