Evolving and Supporting Stateful, Multi-Tenant Decisioning Applications in Production
summary
Kubernetes runs a stateful, multi-tenant decisioning platform that stitches Apache NiFi for ETL, Kafka as the persistent stream backbone, Flink for real‑time decisioning, Pachyderm for versioned-data model refits, and Drill/Zeppelin for ad‑hoc analytics. Cluster automations enforce a 60‑day rehydration, PersistentVolumes + StatefulSets handle state, and resource quotas plus pod affinities prevent noisy neighbors. Production workloads process ~6 million transactions/day, retain 180 days of stream data, and currently use a shared Flink cluster with a CLI/CRD path toward per‑tenant clusters.
AI-written summary · about
chapters (25)
- 0:00Intro
- 0:48Welcome to balmy Austin!
- 2:12Our experience with K8s
- 5:10Production Workloads
- 9:26T1: Decisioning Engine
- 10:25Model Refit with Pachyderm
- 11:04Analytical Environment
- 12:39Telemetry: Responsive Reactive
- 13:21Def. State and Multi-Tenancy
- 14:49Value to customers - a managed service
- 15:45So you want to be a platform provider? Customer interactions to expect
- 16:37"Well-behaved" kes workloads
- 18:02Your experience?
- 18:57Tenant Isolation - Namespacing
- 19:47Stateful Applications & Pod-Volume Affinity
- 21:10Sidebar: Automated Upgrades & "Rehydration"
- 22:27Lessons Learned: Safety First!
- 24:05Future state: Elastic/Dynamic Load
- 24:45Kubernetes should be invisible
- 25:59Current User/Platform Interaction
- 27:45Learning Opportunities
- 28:33Future User/Platform Interaction
- 30:42K8s Architecture: C.f. In-flight drone maintenance
- 32:22Conclusions
- 34:42Community Shout-out!
related talks
26mKubernetes & real-time analytics: How to connect these worlds with Apache Flink
16mZero-downtime upgrades of Flink applications
36mKubernetes, Decisions
34mTransforming Data Processing with Kubernetes: Journey Towards a Self-Serve Data Mesh
24mDynamic Big Data in the Cloud with Kubernetes
05mLightning Talk: What Makes a Good Multi-tenant Kubernetes Solution?
58mReal-Time ML Applications at Scale with Flink and Beam on Kubernetes and GCP
37mSpark and Flink Running Scalable in Kubernetes #bbuzz
