Hai un job Cloud Dataflow di streaming in esecuzione; gli ingegneri hanno prodotto una nuova versione con windowing e trigger diversi. Per aggiornare senza perdita di dati, cosa dovresti fare?

Per aggiornare un job Dataflow di streaming senza perdita di dati e con modifiche significative come il windowing e i trigger, la strategia migliore è arrestare il job esistente usando l'opzione "Drain" e poi avviare un nuovo job con il codice aggiornato. "Drain" assicura che tutti i dati in transito vengano elaborati prima che il job si fermi, prevenendo la perdita di dati. L'opzione "Cancel" interromperebbe immediatamente il job, causando la perdita dei dati non ancora elaborati. L'aggiornamento in-flight (con --update) è adatto per modifiche minori che non alterano la logica di windowing o lo stato del job, ma non per cambiamenti strutturali come quelli descritti, che richiedono un riavvio pulito per applicare correttamente le nuove configurazioni.