В моем конвейере есть скользящее окно времени события, и оно прекрасно работает, за исключением случаев, когда я ввожу контрольные точки.
Контрольная точка обычно проходит успешно, но в случае сбоя приложение пытается(и успешно) восстановить к этой контрольной точке, НО водяные знаки теперь отстают и не догоняют в реальном времени.
Есть ли какое-то решение для этого?