LeetQuiz Logo
Privacy Policy•contact@leetquiz.com
© 2025 LeetQuiz All rights reserved.
Google Professional Data Engineer

Google Professional Data Engineer

Get started today

Ultimate access to all questions.


You are operating a Dataflow streaming pipeline that utilizes both the Streaming Engine and Horizontal Autoscaling features. The pipeline's maximum worker limit has been set to 1,000 workers. The input for this pipeline consists of Pub/Sub messages that relay notifications from Cloud Storage. One of the transformations in the pipeline involves reading CSV files, and it emits an element for each line in the CSV. However, you are experiencing low job performance; the pipeline is currently only employing 10 workers, and the autoscaler isn't scaling up to add more workers. What steps should you take to enhance the performance of the pipeline?

Exam-Like



Powered ByGPT-5