Je hebt een actieve streaming Cloud Dataflow-taak; engineers hebben een nieuwe versie geproduceerd met andere windowing en triggers. Wat moet je doen om te updaten zonder gegevensverlies?

De correcte procedure is om de Dataflow-taak te stoppen met de 'Drain'-optie en vervolgens een nieuwe taak te starten met de bijgewerkte code. 'Drain' zorgt ervoor dat alle reeds verwerkte gegevens worden afgerond en alle in-flight gegevens worden verwerkt voordat de taak stopt, wat gegevensverlies voorkomt. De 'Cancel'-optie stopt de taak onmiddellijk en kan leiden tot gegevensverlies van in-flight elementen. Het direct updaten van een actieve streamingtaak met --update is niet mogelijk als de wijzigingen betrekking hebben op windowing of triggers, omdat dit structurele veranderingen zijn die een herstart vereisen. Het gebruik van een nieuwe jobnaam bij --update is ook niet van toepassing, omdat dit geen methode is om een actieve streamingtaak met dergelijke wijzigingen te updaten.