Netflix Flink autoscaling migration cuts compute costs by 58 percent
Netflix is migrating its internal Flink autoscaling infrastructure to the open-source Apache Flink Autoscaler to manage over 30,000 jobs. The transition enables more granular scaling for complex stateful DAGs and has resulted in a 58% reduction in compute expenditures for specific telemetry workloads.
Key Takeaways
- Telemetry workloads saw a 58% reduction in compute expenditures, saving approximately $1.1 million annually.
- The new system uses True Processing Rate (TPR) to estimate capacity by dividing throughput by the fraction of time an operator is busy.
- Netflix integrated the autoscaler library with Temporal workflows to isolate the blast radius of individual job failures.
- Internal modifications were required to handle high-parallelism jobs of up to 3,000 subtasks and preserve forward-connected subgraphs.
Why It Matters
The shift from proprietary internal tools to open-source frameworks highlights a maturation in stream processing where community-driven logic now outperforms custom-built solutions for complex DAGs. By adopting the Apache Flink Autoscaler, Netflix reduces the engineering overhead of maintaining a bespoke system while gaining the ability to scale stateful workloads that were previously managed manually. This move reflects a broader industry trend toward standardized infrastructure that can handle the massive data volumes required for live events and real-time personalization. Watch for Netflix to integrate Flink 2.2 and its disaggregated state architecture to further minimize the time-intensive restart and recovery cycles currently required during scaling events.
Additional Context
Apache Flink's autoscaler has become a focal point for large-scale stream processing operators seeking to reduce manual tuning overhead. In early 2025, Confluent announced native integration of the Flink Autoscaler into its managed Flink service, enabling customers to automatically adjust parallelism based on backlog metrics and processing latency without custom operator logic. The move signaled that cloud-managed Flink providers were treating autoscaling as a table-stakes capability rather than a differentiator, which aligns with Netflix's decision to standardize on the community project rather than maintain a proprietary alternative. Ververica, the commercial entity behind Flink's original development, published benchmarks showing the autoscaler reduced over-provisioning by up to 40 percent in production workloads during 2025, providing independent validation of the cost savings Netflix reported for its telemetry pipelines.
The business case for open-source Flink autoscaling intersects with broader cloud cost governance pressures facing streaming platforms. AWS introduced enhanced cost allocation tags for Amazon Kinesis Data Streams in late 2025, giving operators finer-grained visibility into per-stream spend and making it easier to justify autoscaling investments with concrete ROI data. Netflix's reliance on AWS as its primary compute substrate means that tighter cost attribution directly supports the business case for migrating 30,000 jobs to a system that can right-size resources dynamically. Meanwhile, Databricks completed its acquisition of Tabular, the company founded by Flink's original creators, in June 2025, consolidating commercial Flink expertise under a data-lakehouse vendor and raising questions about the long-term governance of the Flink ecosystem that Netflix and other large adopters depend on.
On the technical side, the Flink community has continued advancing the autoscaler's capabilities for stateful workloads. Flink 2.0, released in March 2025, introduced disaggregated state management through the ForSt state backend, which separates state storage from compute nodes and enables faster rescaling by avoiding full state downloads during parallelism changes. This architectural shift directly addresses the restart latency problem that Netflix identified as a limitation of its previous autoscaling approach, where scaling events required full checkpoint restoration. A benchmark study published by the Apache Flink community in mid-2025 demonstrated that ForSt reduced state recovery time by approximately 60 percent compared to RocksDB for workloads exceeding 100 GB of state, suggesting that Netflix's planned adoption of Flink 2.x features could yield additional efficiency gains beyond the 58 percent compute reduction already achieved through autoscaler migration alone.
Read full article at netflixtechblog.com
Enjoy our coverage?
Add StreamingMeme as a preferred source on Google to see more of our streaming news at the top of your Search results.
Add as preferred source