Flinking, Fast and Slow
summary
Built the company’s first Flink service in production that reads from Kafka, runs two Flink jobs (map/reduce then watermarking), writes to Kafka and an internal datastore on a daily cadence, and successfully scales to high throughput. Adoption requires slowing rollout: invest a dedicated Flink expert, redefine ownership of upstream/downstream monitoring, provide internal advocate program (blog posts, talks, Slack support), and add code for savepoint storage and container/image hosting to meet operational needs.
AI-written summary · about
chapters (9)
- 0:00Introduction and background
- 1:07Early adoption challenges
- 3:15Use case and architecture overview
- 5:41Integration challenges and solutions
- 8:12Building internal flink advocates
- 11:22Operational needs and infrastructure
- 13:49Expertise and resource allocation
- 16:20Impact of flink’s speed on ecosystem
- 18:29Conclusion and Q&A
related talks
45mThe State of Flink and how to adopt Stream Processing
38mFrom Flink 1.3 to 1.4
30mBlink: Improvements to Flink & its application in Alibaba Search
35mBeyond the Watermark: On-Demand Backfilling in Flink
38mBridging the Chasm Between Research & Software Development
47mAll the DataOps, all the paradigms
34mBuilding High Resiliency into Digital Solutions
42mColliding worlds or bending Spark towards enterprise needs
