Google Cloud Professional Data Engineer PDE — Topic 1 Question 143

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?

Accepted Answer

Correct answer: D. The correct answer is D. Option D: Stop the Cloud Dataflow pipeline with the Drain option. Create a new Cloud Dataflow job with the updated code Dataflow runs serverless Apache Beam pipelines for stream and batch data processing with autoscaling. This option meets the real-time / low-latency performance requirement.

Google Cloud Professional Data Engineer PDE — Question 143