Seminar Apache Flink Stateful Stream Processing und Fault Tolerance

State, Zeitsemantik und Wiederanlauf sind der Kern von Apache Flink. Wer diese Themen nur oberflächlich versteht, baut früher oder später Jobs, die im Demo-Setup glänzen und in der Produktion unerquicklich werden. Dieses Seminar geht deshalb gezielt in die Tiefe.

Zielsetzung

Ziel ist ein belastbares Verständnis dafür, wie zustandsbehaftete Logik modelliert, wie verspätete Daten korrekt behandelt und wie Recovery, Rescaling und Änderungen an laufenden Jobs sauber umgesetzt werden.

Zielgruppe

Das Seminar richtet sich an fortgeschrittene Teams, die komplexe Streaming-Anwendungen entwickeln oder bestehende Jobs robuster, nachvollziehbarer und wartbarer machen wollen.

Schwerpunkte

• Keyed State, Operator State, Broadcast State und deren sinnvolle Einsatzmuster
• Event Time, Watermarks, Fensterlogik, verspätete Ereignisse und kontrollierter Umgang mit Unordnung im Datenstrom
• Exactly-once-Konzepte, Checkpoints, Savepoints, Wiederanlauf und Versionierung zustandsbehafteter Anwendungen
• State TTL, Zustandsgröße, Speicherverhalten und Auswirkung fachlicher Modellierung auf Betrieb und Kosten
• Prozesslogik mit Timern, Regeln, Mustererkennung und erweiterten Operator-Mustern
• Fehlerbilder bei State-Migration, Recovery, Rescaling und inkonsistenten Nebenwirkungen

Praxisanteil

In den Übungen werden Zustandsmodelle aufgebaut, Zeitverhalten sichtbar gemacht und Wiederanläufe einschließlich Savepoint-Szenarien praktisch nachvollzogen. Genau dort trennt sich meist solides Engineering vom bloßen Hoffen.