Google Professional Data Engineer Practice Test 22
Question 210
A Google Cloud architecture review finds: A reporting table is updated from multiple partners, and records arriving days late overwrite newer authoritative versions. Which principle BEST explains the underlying data-engineering risk?
- Data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone.
- Recovery objectives should drive resilient data placement, backups, and executable failover procedures.
- Transformation orchestration must enforce dependency order and freshness contracts.
- Generated SQL needs explicit validation, permission boundaries, and review before modifying governed data.
Explanation
Correct Answer
A:Data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone. This principle identifies the relevant workload or governance requirement. The engineer should first examine: Examine event times, source priority, change sequence, and BigQuery merge logic. A focused corrective action is: Implement version-aware merges with authoritative ordering and an auditable correction pathway.
Incorrect Answers
B:Recovery objectives should drive resilient data placement, backups, and executable failover procedures. This addresses a different situation: A regional processing failure stops daily regulatory datasets because all staging, computation, and recovery copies reside in one failure domain. The current scenario instead calls for the more directly applicable principle: Data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone. The reason is that data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone.
C:Transformation orchestration must enforce dependency order and freshness contracts. This addresses a different situation: A Dataform pipeline materializes monthly revenue before its upstream exchange-rate table refresh completes. The current scenario instead calls for the more directly applicable principle: Data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone. The reason is that data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone.
D:Generated SQL needs explicit validation, permission boundaries, and review before modifying governed data. This addresses a different situation: An analytics team uses LLM-generated BigQuery SQL and executes it immediately against production tables with write privileges. The current scenario instead calls for the more directly applicable principle: Data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone. The reason is that data fidelity depends on business-time semantics and conflict-resolution rules rather than arrival order alone.
Question 211
After applying the change, the team re-examines this condition: A mobile field-work app stores flexible nested inspection documents and synchronizes changes through supported client libraries. Which result BEST verifies the improvement?
- Representative OLTP and read-heavy workloads meet measured latency and consistency targets.
- A recovery query returns the expected pre-migration records within the target window.
- A simulated cache outage falls back safely without losing authoritative inventory changes.
- A mobile user can read only authorized inspections and query the intended indexed fields.
Explanation
Correct Answer
D:A mobile user can read only authorized inspections and query the intended indexed fields. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Choose a Firestore document model with carefully scoped security rules and indexes. Firestore offers managed document storage suitable for document access patterns and supported client needs.
Incorrect Answers
A:Representative OLTP and read-heavy workloads meet measured latency and consistency targets. This addresses a different situation: A PostgreSQL-compatible application has intensive operational transactions plus complex analytical queries and wants compatible managed performance options. The current scenario instead calls for the more directly applicable verification result: A mobile user can read only authorized inspections and query the intended indexed fields. The reason is that firestore offers managed document storage suitable for document access patterns and supported client needs.
B:A recovery query returns the expected pre-migration records within the target window. This addresses a different situation: A PostgreSQL operational service needs to restore state from immediately before a faulty data migration, not merely from the last weekly export. The current scenario instead calls for the more directly applicable verification result: A mobile user can read only authorized inspections and query the intended indexed fields. The reason is that firestore offers managed document storage suitable for document access patterns and supported client needs.
C:A simulated cache outage falls back safely without losing authoritative inventory changes. This addresses a different situation: An ecommerce service repeatedly looks up the same short-lived inventory recommendations and overwhelms its primary datastore during traffic peaks. The current scenario instead calls for the more directly applicable verification result: A mobile user can read only authorized inspections and query the intended indexed fields. The reason is that firestore offers managed document storage suitable for document access patterns and supported client needs.
Question 212
A Google Cloud architecture review finds: A same-day executive dashboard competes with a large nonurgent nightly historical rebuild. Which principle BEST explains the underlying data-engineering risk?
- Job priority and capacity policies should reflect latency sensitivity and business importance.
- Flexible capacity and assignment strategies can isolate occasional bursts without starving core reporting.
- Capacity pricing and reservations should be evaluated against measured utilization and service commitments.
- Business-critical data processing should have planned resource isolation and failover controls.
Explanation
Correct Answer
A:Job priority and capacity policies should reflect latency sensitivity and business importance. This principle identifies the relevant workload or governance requirement. The engineer should first examine: Inspect query job priorities, deadlines, slot utilization, and reservation assignments. A focused corrective action is: Use appropriate interactive and batch workload controls with guaranteed critical capacity.
Incorrect Answers
B:Flexible capacity and assignment strategies can isolate occasional bursts without starving core reporting. This addresses a different situation: A data science team needs occasional huge feature-engineering runs but competes with a permanently reserved reporting workload. The current scenario instead calls for the more directly applicable principle: Job priority and capacity policies should reflect latency sensitivity and business importance. The reason is that job priority and capacity policies should reflect latency sensitivity and business importance.
C:Capacity pricing and reservations should be evaluated against measured utilization and service commitments. This addresses a different situation: A platform has steady high-volume SQL demand but is paying unpredictable per-query cost while finance requires capacity budgets. The current scenario instead calls for the more directly applicable principle: Job priority and capacity policies should reflect latency sensitivity and business importance. The reason is that job priority and capacity policies should reflect latency sensitivity and business importance.
D:Business-critical data processing should have planned resource isolation and failover controls. This addresses a different situation: A payment streaming system is operationally critical, but monthly experimentation triggers heavy resource contention and delayed settlement events. The current scenario instead calls for the more directly applicable principle: Job priority and capacity policies should reflect latency sensitivity and business importance. The reason is that job priority and capacity policies should reflect latency sensitivity and business importance.
Question 213
Before modifying the data platform, the team observes: An analytics query sorts a multi-terabyte table globally before returning 20 leaderboard entries, exhausting resources. Which evidence should the engineer examine FIRST?
- Review dashboard SQL, data sizes, cache applicability, reservation use, and latency profiles.
- Inspect SQL construction, parameter values, connector authorization, and query errors.
- Review query execution stages, joins, ORDER BY, LIMIT, and slot usage.
- Inspect query plan, partition filter expressions, bytes processed, and table partitioning.
Explanation
Correct Answer
C:Review query execution stages, joins, ORDER BY, LIMIT, and slot usage. This evidence directly tests the uncertain part of the described system. Analytical query plans should reduce large intermediates and sort only necessary data. A controlled response is: Restructure the aggregation and limit after appropriate grouping with efficient filtering.
Incorrect Answers
A:Review dashboard SQL, data sizes, cache applicability, reservation use, and latency profiles. This addresses a different situation: A high-traffic operational dashboard executes recurring BigQuery aggregations and users complain about slow interactive response. The current scenario instead calls for the more directly applicable investigation: Review query execution stages, joins, ORDER BY, LIMIT, and slot usage. The reason is that analytical query plans should reduce large intermediates and sort only necessary data.
B:Inspect SQL construction, parameter values, connector authorization, and query errors. This addresses a different situation: A dashboard generates dynamic SQL by concatenating raw user text into filters and risks malformed or unsafe queries. The current scenario instead calls for the more directly applicable investigation: Review query execution stages, joins, ORDER BY, LIMIT, and slot usage. The reason is that analytical query plans should reduce large intermediates and sort only necessary data.
D:Inspect query plan, partition filter expressions, bytes processed, and table partitioning. This addresses a different situation: An analyst filters a partitioned BigQuery table by wrapping the partition column in a complex function and sees a costly full scan. The current scenario instead calls for the more directly applicable investigation: Review query execution stages, joins, ORDER BY, LIMIT, and slot usage. The reason is that analytical query plans should reduce large intermediates and sort only necessary data.
Question 214
A Google Cloud architecture review finds: A global order platform needs strongly consistent relational transactions across geographic users and plans to scale beyond a single traditional database instance. Which principle BEST explains the underlying data-engineering risk?
- Bigtable is appropriate for certain high-throughput low-latency key-oriented workloads when row-key design is sound.
- AlloyDB may suit demanding PostgreSQL-compatible operational workloads when measured capabilities and costs fit.
- Spanner supports distributed relational transactions with strong consistency, subject to schema and locality design.
- Partitioning and clustering can reduce eligible BigQuery query scanning when aligned with predicates.
Explanation
Correct Answer
C:Spanner supports distributed relational transactions with strong consistency, subject to schema and locality design. This principle identifies the relevant workload or governance requirement. The engineer should first examine: Review transaction isolation needs, region placement, query patterns, and write contention. A focused corrective action is: Design a Spanner schema with appropriate primary keys and multi-region placement where justified.
Incorrect Answers
A:Bigtable is appropriate for certain high-throughput low-latency key-oriented workloads when row-key design is sound. This addresses a different situation: A logistics app needs millisecond lookups for enormous numbers of sparse sensor rows keyed by device and time, with no requirement for SQL joins. The current scenario instead calls for the more directly applicable principle: Spanner supports distributed relational transactions with strong consistency, subject to schema and locality design. The reason is that spanner supports distributed relational transactions with strong consistency, subject to schema and locality design.
B:AlloyDB may suit demanding PostgreSQL-compatible operational workloads when measured capabilities and costs fit. This addresses a different situation: A PostgreSQL-compatible application has intensive operational transactions plus complex analytical queries and wants compatible managed performance options. The current scenario instead calls for the more directly applicable principle: Spanner supports distributed relational transactions with strong consistency, subject to schema and locality design. The reason is that spanner supports distributed relational transactions with strong consistency, subject to schema and locality design.
D:Partitioning and clustering can reduce eligible BigQuery query scanning when aligned with predicates. This addresses a different situation: A warehouse stores years of events and most reports filter by event date and customer segment, but all queries scan the full table. The current scenario instead calls for the more directly applicable principle: Spanner supports distributed relational transactions with strong consistency, subject to schema and locality design. The reason is that spanner supports distributed relational transactions with strong consistency, subject to schema and locality design.
Question 215
After applying the change, the team re-examines this condition: A Dataflow batch pipeline processes a few large files using hundreds of workers while bottlenecked on one serialized source stage. Which result BEST verifies the improvement?
- Restarting a failed DAG does not double-charge a test invoice.
- A representative batch finishes at comparable speed with fewer wasted worker-hours.
- A simulated batch peak no longer violates the protected interactive dashboard SLO.
- A workload trial meets its deadline while unnecessary idle worker-hours decline.
Explanation
Correct Answer
B:A representative batch finishes at comparable speed with fewer wasted worker-hours. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Right-size workers and improve the serial input bottleneck before increasing capacity. Worker cost optimization must follow actual pipeline parallelism and bottlenecks.
Incorrect Answers
A:Restarting a failed DAG does not double-charge a test invoice. This addresses a different situation: An Airflow DAG reruns after scheduler recovery and reissues the same external billing update twice. The current scenario instead calls for the more directly applicable verification result: A representative batch finishes at comparable speed with fewer wasted worker-hours. The reason is that worker cost optimization must follow actual pipeline parallelism and bottlenecks.
C:A simulated batch peak no longer violates the protected interactive dashboard SLO. This addresses a different situation: Critical dashboards compete with scheduled ETL jobs for BigQuery slots and miss interactive latency targets. The current scenario instead calls for the more directly applicable verification result: A representative batch finishes at comparable speed with fewer wasted worker-hours. The reason is that worker cost optimization must follow actual pipeline parallelism and bottlenecks.
D:A workload trial meets its deadline while unnecessary idle worker-hours decline. This addresses a different situation: A large Spark cluster remains at peak worker count during long idle stages because autoscaling is disabled. The current scenario instead calls for the more directly applicable verification result: A representative batch finishes at comparable speed with fewer wasted worker-hours. The reason is that worker cost optimization must follow actual pipeline parallelism and bottlenecks.
Question 216
A Google Cloud data engineer is addressing: A churn model trains on a cancellation timestamp that becomes known only after the customer leaves, producing unrealistic validation accuracy. Which TWO complementary actions should the team take? Select TWO answers.
- Version reusable transformations and validate feature parity between training and serving.
- Inspect feature timestamps, training joins, holdout splits, and online availability.
- Inspect document types, OCR quality, extracted text, language detection, and document access.
- Record versioned model artifacts and approval criteria with reproducible training inputs.
- Build point-in-time-correct training examples and retrain with only eligible predictors.
Explanation
Correct Answers
B:Inspect feature timestamps, training joins, holdout splits, and online availability. This is the applicable diagnostic investigation. Its complementary step is: Build point-in-time-correct training examples and retrain with only eligible predictors. Together they address: Predictive features must be available at the intended prediction time to avoid target leakage.
E:Build point-in-time-correct training examples and retrain with only eligible predictors. This is the applicable controlled engineering response. Its complementary step is: Inspect feature timestamps, training joins, holdout splits, and online availability. Together they address: Predictive features must be available at the intended prediction time to avoid target leakage.
Incorrect Answers
A:Version reusable transformations and validate feature parity between training and serving. This could be useful for another system: A production model receives categorical values in a format different from the BigQuery ML training transformations. For this situation, the necessary paired decisions are to examine (Inspect feature timestamps, training joins, holdout splits, and online availability.) and to implement (Build point-in-time-correct training examples and retrain with only eligible predictors.).
C:Inspect document types, OCR quality, extracted text, language detection, and document access. This could be useful for another system: A records team ingests scanned PDFs for semantic search but indexes raw unreadable binary bytes as if they were meaningful text. For this situation, the necessary paired decisions are to examine (Inspect feature timestamps, training joins, holdout splits, and online availability.) and to implement (Build point-in-time-correct training examples and retrain with only eligible predictors.).
D:Record versioned model artifacts and approval criteria with reproducible training inputs. This could be useful for another system: A data scientist overwrites a BigQuery ML model each week and has no record of which training window produced the current predictions. For this situation, the necessary paired decisions are to examine (Inspect feature timestamps, training joins, holdout splits, and online availability.) and to implement (Build point-in-time-correct training examples and retrain with only eligible predictors.).
Question 217
Before modifying the data platform, the team observes: A finance department publishes unreviewed experiment tables to the company-wide BI directory and consumers treat them as financial statements. Which evidence should the engineer examine FIRST?
- Inspect tenant identifiers, user groups, row access policies, and sample access tests.
- Review lineage, approval records, data quality checks, and access destinations.
- Audit embedded viewer roles, export permissions, data source privileges, and contracts.
- Inspect subscriber relationships, listing permissions, audit events, and data ownership.
Explanation
Correct Answer
B:Review lineage, approval records, data quality checks, and access destinations. This evidence directly tests the uncertain part of the described system. Data publication should distinguish certified, governed outputs from exploratory drafts. A controlled response is: Create a controlled publication process for certified datasets and report definitions.
Incorrect Answers
A:Inspect tenant identifiers, user groups, row access policies, and sample access tests. This addresses a different situation: A SaaS analytics platform hosts multiple tenant records in one BigQuery table, and users may see only their organization's rows. The current scenario instead calls for the more directly applicable investigation: Review lineage, approval records, data quality checks, and access destinations. The reason is that data publication should distinguish certified, governed outputs from exploratory drafts.
C:Audit embedded viewer roles, export permissions, data source privileges, and contracts. This addresses a different situation: An embedded dashboard lets viewers export all underlying data even though contracts permit only monthly aggregates. The current scenario instead calls for the more directly applicable investigation: Review lineage, approval records, data quality checks, and access destinations. The reason is that data publication should distinguish certified, governed outputs from exploratory drafts.
D:Inspect subscriber relationships, listing permissions, audit events, and data ownership. This addresses a different situation: A business data provider wants to revoke a partner's access to an outdated analytics feed without invalidating access for other subscribers. The current scenario instead calls for the more directly applicable investigation: Review lineage, approval records, data quality checks, and access destinations. The reason is that data publication should distinguish certified, governed outputs from exploratory drafts.
Question 218
After applying the change, the team re-examines this condition: A large BigQuery query fails with resources-exceeded errors and the operator sees only a generic dashboard red indicator. Which result BEST verifies the improvement?
- The same input query produces correct output without repeating the resource failure.
- One failed sample run can be traced from source receipt to the failing transformation.
- A seeded invalid row triggers an owned alert before the affected dataset is published.
- A test stalled watermark triggers an actionable alert even though the job remains Running.
Explanation
Correct Answer
A:The same input query produces correct output without repeating the resource failure. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Refactor the identified heavy stage or adjust supported capacity after explaining the bottleneck. Troubleshooting requires job-stage metrics, execution details, and precise failure context.
Incorrect Answers
B:One failed sample run can be traced from source receipt to the failing transformation. This addresses a different situation: A daily pipeline fails across multiple microservices, but logs cannot connect the initial import to the final BigQuery job. The current scenario instead calls for the more directly applicable verification result: The same input query produces correct output without repeating the resource failure. The reason is that troubleshooting requires job-stage metrics, execution details, and precise failure context.
C:A seeded invalid row triggers an owned alert before the affected dataset is published. This addresses a different situation: An automated Dataform transform completes, but one critical assertion reports failed rows and no team is notified. The current scenario instead calls for the more directly applicable verification result: The same input query produces correct output without repeating the resource failure. The reason is that troubleshooting requires job-stage metrics, execution details, and precise failure context.
D:A test stalled watermark triggers an actionable alert even though the job remains Running. This addresses a different situation: A stream's reported job state stays Running while the actual consumer watermark stops moving for twenty minutes. The current scenario instead calls for the more directly applicable verification result: The same input query produces correct output without repeating the resource failure. The reason is that troubleshooting requires job-stage metrics, execution details, and precise failure context.
Question 219
Before modifying the data platform, the team observes: A batch Hadoop estate has custom Spark jobs and HDFS storage tightly coupled to aging servers. Which evidence should the engineer examine FIRST?
- Interview dashboard owners and review usage logs, critical deadlines, and data contracts.
- Inventory Spark versions, HDFS paths, library dependencies, SLAs, and target data locations.
- Review source system connector support, synchronization frequency, credentials, and dataset location.
- Inspect source file versions, checksums, arrival timestamps, and ingestion checkpoints.
Explanation
Correct Answer
B:Inventory Spark versions, HDFS paths, library dependencies, SLAs, and target data locations. This evidence directly tests the uncertain part of the described system. Migration planning should separate compute portability, durable storage, and dependency compatibility. A controlled response is: Pilot managed Dataproc execution with approved Cloud Storage staging and tested dependencies.
Incorrect Answers
A:Interview dashboard owners and review usage logs, critical deadlines, and data contracts. This addresses a different situation: A data team migrates an operational reporting platform without identifying owners of critical reports or their acceptance criteria. The current scenario instead calls for the more directly applicable investigation: Inventory Spark versions, HDFS paths, library dependencies, SLAs, and target data locations. The reason is that migration planning should separate compute portability, durable storage, and dependency compatibility.
C:Review source system connector support, synchronization frequency, credentials, and dataset location. This addresses a different situation: An analytics team needs managed recurring imports from an approved external business SaaS source into BigQuery. The current scenario instead calls for the more directly applicable investigation: Inventory Spark versions, HDFS paths, library dependencies, SLAs, and target data locations. The reason is that migration planning should separate compute portability, durable storage, and dependency compatibility.
D:Inspect source file versions, checksums, arrival timestamps, and ingestion checkpoints. This addresses a different situation: A partner shares daily updates while an organization copies older archives into a new Cloud Storage lake. The current scenario instead calls for the more directly applicable investigation: Inventory Spark versions, HDFS paths, library dependencies, SLAs, and target data locations. The reason is that migration planning should separate compute portability, durable storage, and dependency compatibility.
Question 220
After applying the change, the team re-examines this condition: Developers test destructive transformations against the same production dataset used for regulatory reporting. Which result BEST verifies the improvement?
- The pipeline succeeds without personal credentials and cannot read an unrelated restricted source.
- An attempted development-table deletion cannot affect the production reporting dataset.
- A standard analyst queries allowed columns but is denied the tagged risk-score column.
- A test identity queries the authorized dataset but cannot read a separate payroll dataset.
Explanation
Correct Answer
B:An attempted development-table deletion cannot affect the production reporting dataset. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Create isolated nonproduction projects and datasets with masked test fixtures and deployment gates. Separate development and production boundaries limit the impact of exploratory and destructive data operations.
Incorrect Answers
A:The pipeline succeeds without personal credentials and cannot read an unrelated restricted source. This addresses a different situation: A Dataflow job in a processing project reads raw data from an ingestion project but uses a broad human administrator credential. The current scenario instead calls for the more directly applicable verification result: An attempted development-table deletion cannot affect the production reporting dataset. The reason is that separate development and production boundaries limit the impact of exploratory and destructive data operations.
C:A standard analyst queries allowed columns but is denied the tagged risk-score column. This addresses a different situation: Analysts may inspect product transactions but only a small fraud group may see a sensitive risk score in the same table. The current scenario instead calls for the more directly applicable verification result: An attempted development-table deletion cannot affect the production reporting dataset. The reason is that separate development and production boundaries limit the impact of exploratory and destructive data operations.
D:A test identity queries the authorized dataset but cannot read a separate payroll dataset. This addresses a different situation: An analytics contractor needs to query one approved sales dataset, but the administrator proposes granting project-wide BigQuery Admin privileges. The current scenario instead calls for the more directly applicable verification result: An attempted development-table deletion cannot affect the production reporting dataset. The reason is that separate development and production boundaries limit the impact of exploratory and destructive data operations.