All projects

Discipline

Data engineering

I break pipelines on purpose, then check recovery against source, table, and event state.

MySQL CDC → Flink → Iceberg · failure injection

Streaming Reliability Lab

I break a MySQL-to-Flink-to-Iceberg pipeline on purpose, then check that source state, table snapshots, and event IDs still agree after recovery.

5 induced failure classes0 snapshot diffs after recovery