У вас есть запущенное потоковое задание Cloud Dataflow; инженеры выпустили новую версию с другими окнами и триггерами. Что следует сделать для обновления без потери данных?

Остановка задания Dataflow с помощью Drain (слив) позволяет завершить обработку всех данных, находящихся в пути, перед остановкой задания. Это гарантирует, что никакие данные не будут потеряны, поскольку все элементы будут обработаны до конца. После этого можно запустить новое задание с обновленным кодом. Обновление с --update (даже с тем же именем задания) не рекомендуется для изменений, влияющих на окна и триггеры, так как это может привести к непредсказуемому поведению или потере данных из-за несовместимости состояний. Остановка с Cancel (отмена) не дожидается обработки текущих данных, что приводит к их потере.