Google Cloud Professional Data Engineer PDE — Topic 1 Question 268

Question

You created a new version of a Dataflow streaming data ingestion pipeline that reads from Pub/Sub and writes to BigQuery. The previous version of the pipeline that runs in production uses a 5-minute window for processing. You need to deploy the new version of the pipeline without losing any data, creating inconsistencies, or increasing the processing latency by more than 10 minutes. What should you do?

Accepted Answer

Correct answer: C. The correct answer is C. Option C: Drain the old pipeline, then start the new pipeline. This option meets the real-time / low-latency performance requirement.

Google Cloud Professional Data Engineer PDE — Question 268