Queryable State or How to Build a Billing System Without a Database

March 24, 2017 | by Michael Winters

Konstantin Knauf and Maximilian Bode of Munich-based TNG Technology Consulting are no strangers to stateful stream processing. They've been working closely with Apache Flink® for well over a year now, and in their Flink Forward 2016 talk in Berlin, they detailed their experience building an anonymization platform for one of Germany's largest mobile network providers, processing billions of records in near-real-time every day.

And in April 2017, TNG is partnering with data Artisans to provide Apache Flink training for more than 20 of their developers, further spreading Flink expertise within the company.

TNGAt Flink Forward San Francisco, Konstantin and Max will present "Queryable State or How to Build a Billing System Without a Database", getting into a sample use case for one of Flink 1.2.0's new features (which we covered at a high level in a blog post this week, too). TNG
Their talk's abstract provides more detail:

Traditionally, big data applications rely on the Lambda Architecture in
order to achieve low latency as well as completeness. A streaming layer provides real-time previews while a complementary batch layer retrospectively recomputes the correct results. Using a robust stream processor like Apache Flink, we can do without the latter. But can we take it even one step further? This talk will discuss one of the upcoming features of Apache Flink with the potential to do just that.

As a real-world example, we have built a prototype for a robust billing
system based on Flink and Queryable State. On the one hand, the system exposes the current monthly subtotals in real-time to front-end applications, on the other hand it reports the complete results to downstream systems, e.g. for invoicing. As completeness and correctness are core requirements for a billing system, we will demonstrate the system in multiple failure scenarios, including taskmanager and jobmanager failures as well as unavailability of downstream systems. This talk will give you an idea of how “Queryable State” combined with a robust stream processor enables new streaming uses cases and changes the future of streaming application architecture.

Won't be able to make it to Flink Forward San Francisco? No worries. TNG is hosting a Flink meetup in Munich on Thursday, April 27 where they'll present the talk again.

TNG Technology Consulting, founded in 2001, is made up of more than 250 employees in Munich, Germany. The firm provides support in agile software development, administration & operations, and IT management. To see Konstantin and Max's talk along with 25 others, buy your ticket to Flink Forward San Francisco today.

Topics: Flink Forward

Article by:

Michael Winters

Related articles


Sign up for Monthly Blog Notifications

Please send me updates about products and services of Ververica via my e-mail address. Ververica will process my personal data in accordance with the Ververica Privacy Policy.

Our Latest Blogs

by Nico Kruber May 11, 2021

SQL Query Optimization with Ververica Platform 2.4

In my last blog post, Simplifying Ververica Platform SQL Analytics with UDFs, I showed how easy it is to get started with SQL analytics on Ververica Platform and leverage the power of user-defined...

Read More
by Jun Qin March 29, 2021

The Impact of Disks on RocksDB State Backend in Flink: A Case Study

As covered in a recent blog post, RocksDB is a state backend in Flink that allows a job to have state larger than the amount of available memory as the state backend can spill state to local disk....

Read More
by Konstantin Knauf March 10, 2021

Announcing Ververica Platform 2.4

Newest release adds full support for Flink SQL and Flink 1.12, and improves resource utilization via new shared session clusters.

Read More