Стратегии: пересчёт окна (catchup/backfill), сенсор на партицию + SLA, watermark в streaming-слое до Airflow, повторный MERGE за последние N дней ежедневно.
Разбор
- Чистый «раз в день и забыли» ломается на late events.
- Документируйте максимально допустимую задержку.
- Идемпотентный MERGE за sliding window — частый паттерн.
- Алерты на аномальный volume догонялки.
Итог
Late data лечат sliding пересчётом/сенсорами и явным SLA свежести.
