Conference: Nov 5-7, 2018
Workshops: Nov 8–9, 2018
Presentation: Data Decisions With Realtime Stream Processing
Share this on:
What You’ll Learn
- Learn how Facebook is using stream processing at scale.
- Hear why it is important to relieve data scientists from the burden of knowing how stream processing works and learn how to do it.
- Find out how Facebook is using SQL over stream processing.
Abstract
At Facebook, we can move fast and iterate because of our ability to make data-driven decisions. Data from our stream processing systems provide real-time data analytics and insights; the system is also implemented into various Facebook products, which have to aggregate data from many sources. In this talk, we cover:
- the difficulties of stream processing at scale
- the solutions we've created to date
- three case studies on improving the time to deliver insights with data via stream processing
Our case studies include examples from search product development, accelerating daily pipelines in the Data Warehouse, and seamless integration with our machine learning platforms. Each case study shows how we can deliver value to more teams while continuing to abstract the details of stream processing from various teams at Facebook. We conclude by speaking to the future of stream processing.
Interview
Rajesh: My team is working on stream processing, and we are part of the real-time data organization which focuses on faster, simpler, and smarter delivery of data. We want to reduce the time to results for people and our data driven products and people wait on that rely on data driven. Our organization encompasses the stream processing, our real time monitoring, OLAP systems as well as our data visualization infrastructure.
Rajesh: The goal for this talk is to introduce what stream processing is and how we're thinking about it at Facebook. We don't want stream processing to be this entire new ecosystem people code against. We want stream processing to seamlessly integrate into the rest of Facebook's existing infrastructure. People shouldn't know that streaming is happening. The fact that people have to know that streaming is a different platform makes it difficult for people to start consuming and leveraging it. The goal of this talk is to address why stream processing is hard, then walk through three different examples of how we interact with our internal customers to give them better and more seamless access. We're obviously not finished, there is a long way to go, but it gives you a snapshot of we've done so far.
Rajesh: It introduces stream processing, but it quickly jumps into challenges like scalability or distributed aggregation. Why is distributed aggregation hard? What is involved in running multiple data centers, how do you deal with multi-petabyte storage, how you deal with cross-datacenter network bandwidth, what are some of the tips and techniques that you can use for that, how do you deal with late arriving data?
Rajesh: We have our own late-arriving data algorithm, as a result of how we deal with late-arriving data. When you see the myriad of garbage data that you see in the world, it's important to have types, to get statistical conclusions, to decide what windows you are going to keep open, how you track time. I'm going to spend some time on that.
Rajesh: We don't use any open source platform. The only thing we use is HBase for storage.
Rajesh: I think it's more on the software engineering side. We have talked a lot about Flink and Spark and how to merge those, but how do we provide value that automatically can translate stuff? We can't just use stream processing with this and get as much value as possible. There are still some scaling challenges to this. The data scientists should focus more on what they're trying to compute not how to get it done, and we can figure out what's the best way to do that. Data scientists should focus on the accuracy and correctness of the metrics and the queries. And we should just focus about how to get things done. That's the direction that we're taking in stream processing with Facebook.
Rajesh: I want them to understand the type of challenges existing in stream processing. Stop worrying about what is streaming, what is batching, all that stuff. Try to get that as automated as possible. I’ll share examples of techniques in which we've made automation work. Also, I’ll share examples of the real value the streaming can bring. For example, we talk about search experimentation, how we were able to get results from 40 hours down to one hour. With Facebook's continuous push system that we have now, we can do multiple search iterations within a single day. I want people to understand that stream processing in conjunction with a fast release cycle can really help. In order to do that it's infeasible to have people worry about streaming and batch, and the interoperability, there has to be a fluid space between them.
Similar Talks
.
Tracks
-
Architectures You've Always Wondered About
Architectural practices from the world's most well-known properties, featuring startups, massive scale, evolving architectures, and software tools used by nearly all of us.
-
Going Serverless
Learn about the state of Serverless & how to successfully leverage it! Lessons learned in the track hit on security, scalability, IoT, and offer warnings to watch out for.
-
Microservices: Patterns and Practices
Stories of success and failure building modern Microservices, including event sourcing, reactive, decomposition, & more.
-
DevOps: You Build It, You Run It
Pushing DevOps beyond adoption into cultural change. Hear about designing resilience, managing alerting, CI/CD lessons, & security. Features lessons from open source, Linkedin, Netflix, Financial Times, & more.
-
The Art of Chaos Engineering
Failure is going to happen - Are you ready? Chaos engineering is an emerging discipline - What is the state of the art?
-
The Whole Engineer
Success as an engineer is more than writing code. Hear inward looking thoughts on inclusion, attitude, leadership, remote working, and not becoming the brilliant jerk.
-
Evolving Java
Java continues to evolve & change. Track covers Spring 5, async, Kotlin, serverless, the 6-month cadence plans, & AI/ML use cases.
-
Security: Attacking and Defending
Offense and defensive security evolution that application developers should know about including SGX Enclaves, effects of AI, software exploitation techniques, & crowd defense
-
The Practice & Frontiers of AI
Learn about machine learning in practice and on the horizon. Learn about ML at Quora, Uber's Michelangelo, ML workflow with Netflix Meson and topics on Bots, Conversational interfaces, automation, and deployment practices in the space.
-
21st Century Languages
Compile to Native, Microservices, Machine learning... tailor-made languages solving modern challenges, featuring use cases around Go, Rust, C#, and Elm.
-
Modern CS in the Real World
Applied trends in Computer Science that are likely to affect Software Engineers today. Topics include category theory, crypto, CRDT's, logic-based automated reasoning, and more.
-
Stream Processing In The Modern Age
Compelling applications of stream processing using Flink, Beam, Spark, Strymon & recent advances in the field, including Custom Windowing, Stateful Streaming, SQL over Streams.
-
Performance Mythbusting
Real world, applied performance proofs across stacks. Hear performance consideratiosn for .NET, Python, & Java. Learn performance use cases with OpenJ9, Instagram, and Netflix.
-
Tools and Culture: What's Beyond a Stack of Containers?
Containers are not just a techology. It's a platform. Push your knowledge.
-
Web as Platform
All things Browser, from JavaScript Frameworks for animation and AR / VR to Web Assembly and from protocol work to open standards evolution.
-
Beyond Being an Individual Contributor
Beyond being an individual contributor. Building and Evolving managers and tech leadership.
-
Building Great Engineering Cultures
Why engineering culture matters. Track features org scaling, memes as a culture tool, Ally skills, and panels on diversity / inclusion.
-
Hardware Frontiers: Changes Affecting Software Developers Today
Topics around: Quantum computing, NVM, SMR, GPU, custom hardware, self-driving cars, and mobile hardware.