Predictive Maintenance with Apache Flink
summary
Describes a deployed Predictive Maintenance product called metatron PdM that runs a DNN trained with Keras on TensorFlow/Theano against live sensor streams. Explains the Flink runtime built with Flink DataStream API using event time, sliding windows, timestamps/watermarks, custom sources/sinks and checkpointing for real‑time inference. Compares JVM integration strategies—embedded CPython, TensorFlow Java API, RPC to TensorFlow Serving—and covers delivery with the official Flink Docker image and Flink metrics for monitoring.
AI-written summary · about
chapters (6)
- 0:00Introduction to talk
- 3:49Apache Flink overview
- 12:25Predictive maintenance demo
- 24:26Real-world use cases
- 33:05Challenges and solutions
- 39:16Q&A and closing
related talks
15mData science at scale using Apache Flink: Dynamic model serving and real-time feature generation
35mIntroducing Tensorflow on Flink
20mUsing Flink for Versatile Feature Engineering Pipelines
53mApache Deep Learning 302
21mReal-time Stream Analytics and Scoring Using Apache Flink, Druid & Cassandra
39mOperating Deep Learning Pipelines Anywhere Using Kubeflow
28mEnabling Machine Learning with Apache Flink
25mReal-Time Fraud Detection at Scale
