Google
PROFESSIONAL-DATA-ENGINEER · Question #226
You are operating a streaming Cloud Dataflow pipeline. Your engineers have a new version of the pipeline with a different windowing algorithm and triggering strategy. You want to update the running…
The correct answer is D. Stop the Cloud Dataflow pipeline with the Drain option. Create a new Cloud Dataflow job with the updated code. Explanation/Reference: https://cloud.google.com/dataflow/docs/guides/updating-a-pipeline#changing_windowing
Submitted by noor.lb· Mar 30, 2026Building and operationalizing data processing systems
Question
You are operating a streaming Cloud Dataflow pipeline. Your engineers have a new version of the pipeline with a different windowing algorithm and triggering strategy. You want to update the running pipeline with the new version. You want to ensure that no data is lost during the update. What should you do?
Options
- AUpdate the Cloud Dataflow pipeline inflight by passing the --update option with the --jobName set to the existing job name
- BUpdate the Cloud Dataflow pipeline inflight by passing the --update option with the --jobName set to a new unique job name
- CStop the Cloud Dataflow pipeline with the Cancel option. Create a new Cloud Dataflow job with the updated code
- DStop the Cloud Dataflow pipeline with the Drain option. Create a new Cloud Dataflow job with the updated code
How the community answered
(21 responses)- A14% (3)
- B5% (1)
- C5% (1)
- D76% (16)
Explanation
Explanation/Reference: https://cloud.google.com/dataflow/docs/guides/updating-a-pipeline#changing_windowing
Topics
#Cloud Dataflow#streaming pipeline update#drain#windowing strategy
Community Discussion
No community discussion yet for this question.