Question 40 A telecom company analyzes billions of network events in a Fabric Eventhouse. Events arrive in many tiny bursts that increase ingestion and indexing cost. Which solution is the most defensible for this case? Assume external accelerated Delta shortcuts support every native materialized-view capability Apply time predicates and relevant filters early in KQL queries Enable eligible query acceleration with a justified cache horizon Review ingestion batching and capacity metrics using supported Eventhouse policies Explanation Correct Answer D:Appropriate batching can balance freshness and indexing overhead. Incorrect Answers A:Assume external accelerated Delta shortcuts support every native materialized-view capability would not satisfy events arrive in many tiny bursts that increase ingestion and indexing cost because external KQL tables have feature limitations distinct from native Eventhouse tables; the defensible response is Review ingestion batching and capacity metrics using supported Eventhouse policies. B:The option Apply time predicates and relevant filters early in KQL queries applies to the separate issue that kQL queries scan a very long event history to compute only last-hour faults, because restricting the scanned time and keys reduces unnecessary event processing; the current condition is events arrive in many tiny bursts that increase ingestion and indexing cost, which calls for Review ingestion batching and capacity metrics using supported Eventhouse policies. C:Enable eligible query acceleration with a justified cache horizon is useful when the team queries an external Delta shortcut with slow cross-storage reads, since accelerated shortcut data can improve query speed by caching external records, but incurs resource cost; however, the actual requirement is events arrive in many tiny bursts that increase ingestion and indexing cost, which calls for Review ingestion batching and capacity metrics using supported Eventhouse policies.
Question 41 An airline operates both scheduled warehouse loads and experimental lakehouse notebooks in a Fabric capacity. A Spark job needs a specific configuration only for its isolated execution. Which troubleshooting or configuration step is most appropriate? Set a documented job-level Spark configuration rather than modifying every workspace's default Disable the capacity workload monitoring reports so the team's Spark jobs can run faster Test the new runtime in a separate workspace and validate representative totals before promoting it Review supported Spark autoscale and pool limits with recorded peak job demand Explanation Correct Answer A:A per-job override limits the effect of special settings to the task that requires them. Incorrect Answers B:Choosing Disable the capacity workload monitoring reports so the team's Spark jobs can run faster would not satisfy the case condition (a Spark job needs a specific configuration only for its isolated execution), because removing observability does not increase available processing resources; Set a documented job-level Spark configuration rather than modifying every workspace's default preserves the intended result. C:The action Test the new runtime in a separate workspace and validate representative totals before promoting it solves runtime changes must not silently alter the behavior of month-end financial aggregations because regression comparison on controlled input is stronger evidence than relying on a successful session start; it does not by itself solve a Spark job needs a specific configuration only for its isolated execution, whereas Set a documented job-level Spark configuration rather than modifying every workspace's default does. D:For workloads suddenly consume more Spark executors than the operations budget permits, Review supported Spark autoscale and pool limits with recorded peak job demand can be justified because the Spark pool's resource policy should reflect measured concurrency rather than assuming limitless executor capacity; for this scenario involving a Spark job needs a specific configuration only for its isolated execution, the targeted response is Set a documented job-level Spark configuration rather than modifying every workspace's default.
Question 42 A government data team maintains versioned Fabric warehouse objects with multiple release owners. Security requires who-approved-what history for production schema changes. Which design decision most directly meets the requirement? Deploy an unreviewed DROP TABLE command to test whether production backup works Link approved commits, deployment runs and relevant audit events Restore data through the approved recovery plan rather than relying on DDL rollback alone Resolve source conflicts and validate resulting SQL dependency behavior Explanation Correct Answer B:An executable migration should be attributable to reviewed change approval. Incorrect Answers A:Choosing Deploy an unreviewed DROP TABLE command to test whether production backup works would not satisfy the case condition (security requires who-approved-what history for production schema changes), because destructive live testing is not an appropriate substitute for a recovery rehearsal; Link approved commits, deployment runs and relevant audit events preserves the intended result. C:For a deployment is rolled back but source data still reflects the destructive operation, Restore data through the approved recovery plan rather than relying on DDL rollback alone can be justified because reverting database project code does not automatically recreate deleted business records; for this scenario involving security requires who-approved-what history for production schema changes, the targeted response is Link approved commits, deployment runs and relevant audit events. D:Although Resolve source conflicts and validate resulting SQL dependency behavior fits the separate issue that different engineers propose conflicting modifications to the same SQL view because conflict resolution must produce a single reviewed view definition before publication, this case concerns security requires who-approved-what history for production schema changes and should be resolved with Link approved commits, deployment runs and relevant audit events.
Question 43 A consumer products company publishes a governed Fabric data warehouse to several departments. A privileged analyst sees unmasked values during a security test. What should the data engineer change first? Apply supported dynamic data masking where presentation-level masking is appropriate Inspect role-based unmask privileges and test with a genuinely restricted identity Treat a masked email display as proof that users have no access to any sensitive row or other column Use column-level authorization rather than relying only on dynamic masking Explanation Correct Answer B:Dynamic masking normally permits appropriately privileged principals to see full values, so the test principal matters. Incorrect Answers A:The action Apply supported dynamic data masking where presentation-level masking is appropriate solves a support team can see a customer-email field but should receive only a masked display because dynamic masking changes values presented to unprivileged query consumers without replacing column authorization; it does not by itself solve a privileged analyst sees unmasked values during a security test, whereas Inspect role-based unmask privileges and test with a genuinely restricted identity does. C:Treat a masked email display as proof that users have no access to any sensitive row or other column would not satisfy a privileged analyst sees unmasked values during a security test because presentation masking does not automatically enforce row and object restrictions; the defensible response is Inspect role-based unmask privileges and test with a genuinely restricted identity. D:Option Use column-level authorization rather than relying only on dynamic masking would focus on the separate issue that a team must be prevented from querying the raw customer-email column at all because masking is not a substitute for denying sensitive column access where the data should be inaccessible, not the current requirement that a privileged analyst sees unmasked values during a security test; the appropriate remedy is Inspect role-based unmask privileges and test with a genuinely restricted identity.
Question 44 A regional authority processes traffic-camera metadata in a nightly analytics orchestration. An error-handling task must execute only when the SQL load fails. Which action best addresses the observed Fabric behavior? Use an If Condition expression based on the validated activity output Configure a failure dependency and maintain the upstream error context Use a random failure branch to distribute processing without checking row counts Coordinate supported SQL and notebook activities in a single dependency-aware pipeline Explanation Correct Answer B:Conditional failure paths prevent alerts from being raised for successful work. Incorrect Answers A:For the next stage must choose a branch based on a row-count validation outcome, Use an If Condition expression based on the validated activity output can be justified because conditional branching turns a measured quality result into an explicit orchestration decision; for this scenario involving an error-handling task must execute only when the SQL load fails, the targeted response is Configure a failure dependency and maintain the upstream error context. C:For this requirement of an error-handling task must execute only when the SQL load fails, Use a random failure branch to distribute processing without checking row counts would be unsafe or ineffective because business validation conditions should be deterministic and evidence-driven; apply Configure a failure dependency and maintain the upstream error context instead. D:The option Coordinate supported SQL and notebook activities in a single dependency-aware pipeline applies to the separate issue that some transformations are written in T-SQL and others in PySpark, because pipeline orchestration can sequence heterogeneous compute engines while preserving run metadata; the current condition is an error-handling task must execute only when the SQL load fails, which calls for Configure a failure dependency and maintain the upstream error context.
Question 45 A national weather service delivers hourly measurements from thousands of instruments. Some station messages have missing location metadata. How should the team implement this requirement? Preserve correction versions and upsert or recompute affected historical windows Quarantine or mark the records for reference-data reconciliation before geographic aggregation Introduce an incremental checkpoint on authoritative source event IDs or timestamp/version Interpret missing rainfall as an automatically verified zero for every device Explanation Correct Answer B:Missing station location is a data-quality exception, not evidence that a measurement belongs to an arbitrary district; retain it in a review queue until an authoritative station-to-region mapping is available. Incorrect Answers A:Although Preserve correction versions and upsert or recompute affected historical windows fits the separate issue that devices can emit correction records for an earlier measurement time because late event corrections should revise past aggregates rather than be appended as independent measurements, this case concerns some station messages have missing location metadata and should be resolved with Quarantine or mark the records for reference-data reconciliation before geographic aggregation. C:The option Introduce an incremental checkpoint on authoritative source event IDs or timestamp/version applies to the separate issue that a full daily reload scans the same historical readings every hour, because reliable source progress markers reduce unnecessary old-data reads; the current condition is some station messages have missing location metadata, which calls for Quarantine or mark the records for reference-data reconciliation before geographic aggregation. D:Applying Interpret missing rainfall as an automatically verified zero for every device when some station messages have missing location metadata would introduce a defect because missing telemetry is not evidence of zero precipitation; a direct solution is Quarantine or mark the records for reference-data reconciliation before geographic aggregation.
Question 46 A logistics company transforms nested JSON shipments into a curated Delta table with PySpark. Duplicate package IDs occur because the feed retries delivery. Which solution is the most defensible for this case? Explode the entire parent shipment row four times without preserving package identity Parse and normalize timestamps with explicit timezone assumptions Deduplicate with the declared package key and authoritative source version Use explode on the package array while retaining its parent shipment key Explanation Correct Answer C:Partition-wide distinct rows are not a reliable substitute for business-key conflict rules. Incorrect Answers A:For this requirement of duplicate package IDs occur because the feed retries delivery, Explode the entire parent shipment row four times without preserving package identity would be unsafe or ineffective because repetition without the array's individual element loses package-grain correctness; apply Deduplicate with the declared package key and authoritative source version instead. B:The option Parse and normalize timestamps with explicit timezone assumptions applies to the separate issue that every event timestamp must be compared across different origin time zones, because string comparison of mixed local time formats can give incorrect event ordering; the current condition is duplicate package IDs occur because the feed retries delivery, which calls for Deduplicate with the declared package key and authoritative source version. D:The action Use explode on the package array while retaining its parent shipment key solves each shipment contains an array of individual packages that must become separate rows because exploding preserves package-level grain for downstream scanning and aggregation; it does not by itself solve duplicate package IDs occur because the feed retries delivery, whereas Deduplicate with the declared package key and authoritative source version does.
Question 47 A municipal water network runs stateful Spark streaming over live pressure readings. A high-volume stream should use micro-batch processing with predictable recovery. Which troubleshooting or configuration step is most appropriate? Apply event-time window functions and an appropriate watermark Declare exactly-once business outcomes solely because Spark reports the query is running Review watermark configuration and maximum tolerated lateness Use Spark Structured Streaming with a configured trigger and durable checkpoint Explanation Correct Answer D:A supported micro-batch execution mode combines incremental input and tracked progress. Incorrect Answers A:The option Apply event-time window functions and an appropriate watermark applies to the separate issue that readings arrive out of order and windows should use measured time, because arrival order is not the same as physical measurement chronology; the current condition is a high-volume stream should use micro-batch processing with predictable recovery, which calls for Use Spark Structured Streaming with a configured trigger and durable checkpoint. B:Applying Declare exactly-once business outcomes solely because Spark reports the query is running when a high-volume stream should use micro-batch processing with predictable recovery would introduce a defect because a running stream alone does not prove duplicate-free target commits; a direct solution is Use Spark Structured Streaming with a configured trigger and durable checkpoint. C:The action Review watermark configuration and maximum tolerated lateness solves an operational stateful aggregation never evicts old windows because state retention should track the business's late-event acceptance interval; it does not by itself solve a high-volume stream should use micro-batch processing with predictable recovery, whereas Use Spark Structured Streaming with a configured trigger and durable checkpoint does.
Question 48 A shipping company uses Fabric Data Factory pipelines with several dynamic region parameters. The team needs to know which source file was processed by a particular run. Which design decision most directly meets the requirement? Replace a failed region with data from another region to make its dashboard green Review per-activity execution durations in the pipeline monitoring details Log the run correlation ID and source path or file identity Measure complete elapsed time including retries against the SLA Explanation Correct Answer C:Run-level lineage connects a processing result to concrete input evidence. Incorrect Answers A:Applying Replace a failed region with data from another region to make its dashboard green when the team needs to know which source file was processed by a particular run would introduce a defect because cross-region substitution contaminates measures and can violate permission boundaries; a direct solution is Log the run correlation ID and source path or file identity. B:The action Review per-activity execution durations in the pipeline monitoring details solves the owner asks which activity in a long run consumed most time because activity granularity isolates slow copy or transform steps more accurately than a single total; it does not by itself solve the team needs to know which source file was processed by a particular run, whereas Log the run correlation ID and source path or file identity does. D:Although Measure complete elapsed time including retries against the SLA fits the separate issue that the pipeline retries and reports eventual success but latency breaches the target because a nominal final success can still miss an operational freshness deadline, this case concerns the team needs to know which source file was processed by a particular run and should be resolved with Log the run correlation ID and source path or file identity.
Question 49 A fintech startup receives streaming transactions into Fabric Eventhouse and retains raw Delta copies. A KQL query is unexpectedly slow due to scanning external historical Delta data. What should the data engineer change first? Inspect ingestion failures and correct schema parsing for the rejected payloads Deduplicate by stable transaction event ID and source revision Evaluate shortcut query acceleration and relevant time predicates Publish the secured historical Delta source to an anonymous endpoint to increase query speed Explanation Correct Answer C:External tables can require data fetches and lack native indexes without acceleration. Incorrect Answers A:The action Inspect ingestion failures and correct schema parsing for the rejected payloads solves the source stream contains malformed records that fail the destination mapping because eventhouse throughput alone does not prove the malformed events were accepted; it does not by itself solve a KQL query is unexpectedly slow due to scanning external historical Delta data, whereas Evaluate shortcut query acceleration and relevant time predicates does. B:For the event query shows unexpected duplicate transactions after replay, Deduplicate by stable transaction event ID and source revision can be justified because replay and delivery semantics can create repeated records if business identity is not enforced; for this scenario involving a KQL query is unexpectedly slow due to scanning external historical Delta data, the targeted response is Evaluate shortcut query acceleration and relevant time predicates. D:Choosing Publish the secured historical Delta source to an anonymous endpoint to increase query speed would not satisfy the case condition (a KQL query is unexpectedly slow due to scanning external historical Delta data), because public sharing does not repair the query plan and violates the data-protection intent; Evaluate shortcut query acceleration and relevant time predicates preserves the intended result.
Question 50 A consumer finance company wants faster SQL analytics over curated Fabric data. Row counts changed dramatically after a large incremental load. Which action best addresses the observed Fabric behavior? Evaluate precomputing reusable values or restructuring the query plan Assume a successful query with correct syntax has the cheapest possible execution plan Aggregate or filter at the appropriate business grain before the large join Inspect relevant query optimizer statistics and execution plan quality Explanation Correct Answer D:Statistics can influence join order and estimated costs after major distribution changes. Incorrect Answers A:For an expensive scalar expression is recomputed for every joined row, Evaluate precomputing reusable values or restructuring the query plan can be justified because reusing deterministic results may reduce repeated computation after validating semantics; for this scenario involving row counts changed dramatically after a large incremental load, the targeted response is Inspect relevant query optimizer statistics and execution plan quality. B:For this requirement of row counts changed dramatically after a large incremental load, Assume a successful query with correct syntax has the cheapest possible execution plan would be unsafe or ineffective because sQL correctness and execution efficiency require separate review; apply Inspect relevant query optimizer statistics and execution plan quality instead. C:Option Aggregate or filter at the appropriate business grain before the large join would focus on the separate issue that two fact tables are joined without reducing their grain first because joining raw high-cardinality facts can cause explosive intermediates and memory pressure, not the current requirement that row counts changed dramatically after a large incremental load; the appropriate remedy is Inspect relevant query optimizer statistics and execution plan quality.