Masz uruchomione zadanie strumieniowe Cloud Dataflow; inżynierowie stworzyli nową wersję z innym podziałem na okna (windowing) i wyzwalaczami (triggers). Aby zaktualizować bez utraty danych, co powinieneś zrobić?

Poprawna odpowiedź to zatrzymanie zadania za pomocą opcji Drain i utworzenie nowego zadania. Opcja Drain pozwala na bezpieczne zatrzymanie zadania strumieniowego, przetwarzając wszystkie dane znajdujące się w buforze wejściowym, ale nie akceptując nowych danych. Jest to kluczowe, aby uniknąć utraty danych podczas aktualizacji logiki okienkowania i wyzwalaczy, które są fundamentalnymi zmianami w sposobie przetwarzania strumienia. Użycie opcji Cancel spowodowałoby natychmiastowe zatrzymanie zadania, co mogłoby doprowadzić do utraty danych w trakcie przetwarzania. Aktualizacja zadania za pomocą --update (niezależnie od nazwy zadania) nie jest odpowiednia dla zmian w logice okienkowania i wyzwalaczy, ponieważ te modyfikacje wymagają ponownego uruchomienia potoku od podstaw, aby zapewnić spójność przetwarzania.