Question 520 A financial services company takes hourly copies of a SQL source into a governed Fabric lakehouse. The team wants a one-time historical backfill of an old date range. Which solution is the most defensible for this case? Advance the watermark before the destination commit to speed up retries Select incremental extraction using supported watermark or CDC capabilities Use a bounded parameterized extraction and isolated upsert/reconciliation run Reconcile source and destination counts plus keys before advancing the checkpoint Explanation Correct Answer C:Historical repair should not blindly reset the main production progress checkpoint. Incorrect Answers A:Advance the watermark before the destination commit to speed up retries would not satisfy the team wants a one-time historical backfill of an old date range because a failed target write after an early checkpoint can permanently skip source changes; the defensible response is Use a bounded parameterized extraction and isolated upsert/reconciliation run. B:The option Select incremental extraction using supported watermark or CDC capabilities applies to the separate issue that a daily full snapshot is too expensive for a hundred-million-row source, because loading only changes reduces scanning and network transfer when reliable source change markers exist; the current condition is the team wants a one-time historical backfill of an old date range, which calls for Use a bounded parameterized extraction and isolated upsert/reconciliation run. D:The action Reconcile source and destination counts plus keys before advancing the checkpoint solves the load completed with fewer rows than the source's change report because a successful activity state is not evidence of complete business-row ingestion; it does not by itself solve the team wants a one-time historical backfill of an old date range, whereas Use a bounded parameterized extraction and isolated upsert/reconciliation run does.
Question 521 A freight company moves historical routes from Azure Data Lake into Fabric. Data engineers want existing Delta tables without a bulk copy. Which troubleshooting or configuration step is most appropriate? Place the shortcut in Files for file paths or correctly target Delta tables under Tables Create appropriate OneLake shortcuts targeting the source Delta tables Validate source-side existence and shortcut target freshness instead of repairing an unrelated local table Treat the shortcut as an immutable archive safe from source-side deletion Explanation Correct Answer B:Shortcuts provide logical access to existing compatible tables when authorization allows. Incorrect Answers A:The option Place the shortcut in Files for file paths or correctly target Delta tables under Tables applies to the separate issue that the shortcut exposes plain files rather than a registered Delta table in a lakehouse, because a path's actual format determines whether it can be surfaced as a table; the current condition is data engineers want existing Delta tables without a bulk copy, which calls for Create appropriate OneLake shortcuts targeting the source Delta tables. C:The action Validate source-side existence and shortcut target freshness instead of repairing an unrelated local table solves a referenced source file is deleted but remains expected in the downstream query because a shortcut does not create an independent protected backup of the source; it does not by itself solve data engineers want existing Delta tables without a bulk copy, whereas Create appropriate OneLake shortcuts targeting the source Delta tables does. D:The option Treat the shortcut as an immutable archive safe from source-side deletion fails to meet data engineers want existing Delta tables without a bulk copy, given that logical references inherit availability risks from the target source; Create appropriate OneLake shortcuts targeting the source Delta tables is the correct scope of action.
Question 522 A streaming retail system reads Kafka-compatible purchase events into a Spark lakehouse job. The job must handle a new optional payload field without corrupting the existing schema. Which design decision most directly meets the requirement? Reuse the durable checkpoint and stable Delta sink identity Parse raw JSON strings with an integer cast and expect nested customer fields to appear Review schema evolution and apply an explicitly compatible transformation Configure a hopping event-time window of ten minutes with a five-minute slide Explanation Correct Answer C:Uncontrolled schema inference can alter output contracts as messages change. Incorrect Answers A:Reuse the durable checkpoint and stable Delta sink identity is useful when the stream consumer restarts and must resume from its last successful output commit, since coordinated checkpoint and transactional output avoid unnecessary replay anomalies; however, the actual requirement is the job must handle a new optional payload field without corrupting the existing schema, which calls for Review schema evolution and apply an explicitly compatible transformation. B:Applying Parse raw JSON strings with an integer cast and expect nested customer fields to appear when the job must handle a new optional payload field without corrupting the existing schema would introduce a defect because a scalar cast cannot recover the structure of a JSON object; a direct solution is Review schema evolution and apply an explicitly compatible transformation. D:Although Configure a hopping event-time window of ten minutes with a five-minute slide fits the separate issue that analysts want a ten-minute rolling sales sum refreshed every five minutes because hopping windows overlap by design and are different from nonoverlapping tumbling windows, this case concerns the job must handle a new optional payload field without corrupting the existing schema and should be resolved with Review schema evolution and apply an explicitly compatible transformation.
Question 523 An airline operates near-real-time Eventhouse dashboards and nightly Fabric Warehouse reconciliation. The KQL dashboard is updated but nightly reconciled totals are old. What should the data engineer change first? Inspect partition or source throughput and per-destination lag metrics Compare live Eventhouse ingestion and warehouse batch completion independently Disable nightly reconciliation because the real-time dashboard has recent numbers Inspect model source references and refresh errors against the new destination Explanation Correct Answer B:Streaming and batch serving paths have different freshness and failure states. Incorrect Answers A:The action Inspect partition or source throughput and per-destination lag metrics solves some Eventstream partitions show higher delivery delay than others because uneven input pressure can create partial latency while the overall connector appears healthy; it does not by itself solve the KQL dashboard is updated but nightly reconciled totals are old, whereas Compare live Eventhouse ingestion and warehouse batch completion independently does. C:Disable nightly reconciliation because the real-time dashboard has recent numbers would not satisfy the KQL dashboard is updated but nightly reconciled totals are old because real-time freshness does not establish financial completeness or batch reconciliation; the defensible response is Compare live Eventhouse ingestion and warehouse batch completion independently. D:Option Inspect model source references and refresh errors against the new destination would focus on the separate issue that a semantic model points to an outdated warehouse object after deployment because deployment can change item identity or binding independently of data correctness, not the current requirement that the KQL dashboard is updated but nightly reconciled totals are old; the appropriate remedy is Compare live Eventhouse ingestion and warehouse batch completion independently.
Question 524 A delivery company uses Eventstream to route messages from several queues. A destination receives messages but key fields are null. Which action best addresses the observed Fabric behavior? Correct event schema and destination field mapping Review throughput limits, capacity and sink ingestion metrics before scaling Drop messages whose structure changed without retaining error or schema evidence Update the authorized Eventstream destination connection and retest delivery Explanation Correct Answer A:Partial data delivery can still be an ingestion defect when fields fail conversion. Incorrect Answers B:Although Review throughput limits, capacity and sink ingestion metrics before scaling fits the separate issue that burst traffic causes a growing backlog and late analytics results because backpressure requires evidence of where events queue rather than indiscriminate restarts, this case concerns a destination receives messages but key fields are null and should be resolved with Correct event schema and destination field mapping. C:For this requirement of a destination receives messages but key fields are null, Drop messages whose structure changed without retaining error or schema evidence would be unsafe or ineffective because silent discard hides source-contract regressions and prevents safe recovery; apply Correct event schema and destination field mapping instead. D:The option Update the authorized Eventstream destination connection and retest delivery applies to the separate issue that a destination stops receiving events after its access credentials expire, because destination credentials are required independently of source health; the current condition is a destination receives messages but key fields are null, which calls for Correct event schema and destination field mapping.
Question 525 A manufacturing company consolidates regional Fabric notebooks and warehouse queries. The Delta Gold output accumulates small Parquet files across many regional updates. How should the team implement this requirement? Declare an optimization successful solely because it changed a Spark configuration value Inspect Spark shuffle size and reduce unnecessary repartitioning or wide transformations Benchmark before and after on the same workload using elapsed time, cost and result correctness Schedule appropriate OPTIMIZE or write-size remediation after controlled measurement Explanation Correct Answer D:Compact files reduce scan overhead across Spark and other Delta consumers. Incorrect Answers A:Declare an optimization successful solely because it changed a Spark configuration value would not satisfy the Delta Gold output accumulates small Parquet files across many regional updates because measured run time and correctness, not configuration changes, determine benefit; the defensible response is Schedule appropriate OPTIMIZE or write-size remediation after controlled measurement. B:Option Inspect Spark shuffle size and reduce unnecessary repartitioning or wide transformations would focus on the separate issue that the notebook spends most of its time serializing data between partitions because data movement can dominate compute even when transformation expressions are simple, not the current requirement that the Delta Gold output accumulates small Parquet files across many regional updates; the appropriate remedy is Schedule appropriate OPTIMIZE or write-size remediation after controlled measurement. C:The option Benchmark before and after on the same workload using elapsed time, cost and result correctness applies to the separate issue that managers want to know whether optimization actually improved the SLA, because an optimization should preserve output accuracy while reducing measured resource or latency costs; the current condition is the Delta Gold output accumulates small Parquet files across many regional updates, which calls for Schedule appropriate OPTIMIZE or write-size remediation after controlled measurement.
Question 526 A regional health provider shares a curated lakehouse through Direct Lake semantic models. Row restrictions must apply consistently when consumers query through OneLake-aware engines. Which solution is the most defensible for this case? Review the identity mode and consider supported user-identity access for OneLake-filtered source data Assume workspace admins always experience identical row filtering to restricted report viewers Configure supported OneLake row security and verify each consuming engine's enforcement mode Verify the selected Direct Lake and OneLake identity integration rather than assuming every model mode is equivalent Explanation Correct Answer C:Engine identity and Direct Lake access mode affect whether OneLake policy is evaluated for each user. Incorrect Answers A:Option Review the identity mode and consider supported user-identity access for OneLake-filtered source data would focus on the separate issue that an SQL analytics endpoint uses delegated-owner identity and refuses a secured shortcut source because delegated identity can conflict with secured shortcut sources; per-user enforcement must be deliberate, not the current requirement that row restrictions must apply consistently when consumers query through OneLake-aware engines; the appropriate remedy is Configure supported OneLake row security and verify each consuming engine's enforcement mode. B:Choosing Assume workspace admins always experience identical row filtering to restricted report viewers would not satisfy the case condition (row restrictions must apply consistently when consumers query through OneLake-aware engines), because privileged workspace access and engine identity mode can change effective data permissions; Configure supported OneLake row security and verify each consuming engine's enforcement mode preserves the intended result. D:The action Verify the selected Direct Lake and OneLake identity integration rather than assuming every model mode is equivalent solves a Power BI semantic model over SQL mode does not apply the expected producer restrictions because semantic model access modes vary in how end-user identity is passed through to underlying data; it does not by itself solve row restrictions must apply consistently when consumers query through OneLake-aware engines, whereas Configure supported OneLake row security and verify each consuming engine's enforcement mode does.
Question 527 A retailer copies order records from an operational SQL database to a Fabric Lakehouse each night. The source exposes a reliable last_modified timestamp and only changes should be copied after the first run. Which troubleshooting or configuration step is most appropriate? Persist a successful high-watermark and load records whose modification time falls beyond it Select every row from the source on every failed retry and append it again without a key Evaluate change data capture or another reliable change feed instead of relying on the incomplete timestamp MERGE staged rows by stable order ID and version with an idempotent commit Explanation Correct Answer A:Watermark-based incremental ingestion avoids recopying unchanged records but must preserve the checkpoint consistently. Incorrect Answers B:Applying Select every row from the source on every failed retry and append it again without a key when the source exposes a reliable last_modified timestamp and only changes should be copied after the first run would introduce a defect because repeated append of an entire table can multiply facts and corrupt reported totals; a direct solution is Persist a successful high-watermark and load records whose modification time falls beyond it. C:The action Evaluate change data capture or another reliable change feed instead of relying on the incomplete timestamp solves old orders can be updated without the modification timestamp being maintained because an untrustworthy timestamp misses changes, so the load needs a dependable source change mechanism; it does not by itself solve the source exposes a reliable last_modified timestamp and only changes should be copied after the first run, whereas Persist a successful high-watermark and load records whose modification time falls beyond it does. D:For a nightly run retries after writing a subset of orders, MERGE staged rows by stable order ID and version with an idempotent commit can be justified because keyed merge prevents a replay from creating a second business order row; for this scenario involving the source exposes a reliable last_modified timestamp and only changes should be copied after the first run, the targeted response is Persist a successful high-watermark and load records whose modification time falls beyond it.
Question 528 A bank transforms daily credit risk flags using a Fabric Warehouse. Multiple source rows per account produce inflated account-level totals. Which design decision most directly meets the requirement? Preserve an explicit unknown or invalid status in the curated data Replace all missing risk scores with the highest score and present them as measured values Create distinct snapshot and transaction fact grains with documented aggregation rules Aggregate to the required account grain before joining to one-row dimensions Explanation Correct Answer D:Resolving grain mismatch prevents fan-out and double counting. Incorrect Answers A:Preserve an explicit unknown or invalid status in the curated data is useful when a loan status may be missing and should not be interpreted as approved, since treating NULL as approved would fabricate a business decision; however, the actual requirement is multiple source rows per account produce inflated account-level totals, which calls for Aggregate to the required account grain before joining to one-row dimensions. B:The option Replace all missing risk scores with the highest score and present them as measured values fails to meet multiple source rows per account produce inflated account-level totals, given that an invented measurement is not a validated source fact; Aggregate to the required account grain before joining to one-row dimensions is the correct scope of action. C:For historical balances must be tracked separately from transaction movements, Create distinct snapshot and transaction fact grains with documented aggregation rules can be justified because balance snapshots cannot be summed across dates as if they were independent flow events; for this scenario involving multiple source rows per account produce inflated account-level totals, the targeted response is Aggregate to the required account grain before joining to one-row dimensions.
Question 529 A large hospital operates a Spark Structured Streaming job that enriches de-identified device events. The state store grows until executors run out of memory. What should the data engineer change first? Apply event-time watermarking with an approved lateness threshold Configure a durable Structured Streaming checkpoint location for the query Delete the checkpoint directory every time a Structured Streaming micro-batch fails Review watermark, stateful aggregation keys and checkpoint metrics before raising capacity Explanation Correct Answer D:Unbounded state growth cannot be cured permanently by simply adding executors. Incorrect Answers A:The action Apply event-time watermarking with an approved lateness threshold solves event updates arrive late and must be assigned to their original event-time windows because watermarking governs how long state is retained for delayed events in event-time aggregation; it does not by itself solve the state store grows until executors run out of memory, whereas Review watermark, stateful aggregation keys and checkpoint metrics before raising capacity does. B:For the job must resume after a restart without repeating all prior micro-batches, Configure a durable Structured Streaming checkpoint location for the query can be justified because spark checkpoints preserve source progress and state for supported recovery semantics; for this scenario involving the state store grows until executors run out of memory, the targeted response is Review watermark, stateful aggregation keys and checkpoint metrics before raising capacity. C:For this requirement of the state store grows until executors run out of memory, Delete the checkpoint directory every time a Structured Streaming micro-batch fails would be unsafe or ineffective because resetting checkpoint state can replay records or lose progress and requires a planned recovery decision; apply Review watermark, stateful aggregation keys and checkpoint metrics before raising capacity instead.
Question 530 A city analytics unit operates Fabric workloads during peak monthly reporting. The team cannot explain why multiple pipeline runs wait in queue. Which action best addresses the observed Fabric behavior? Monitor retry counts and failure categories separately from eventual success Increase every scheduled job's concurrency to the maximum without observing capacity Review capacity utilization, activity concurrency and queueing indicators Track refresh duration by query and compare source-row volumes Explanation Correct Answer C:Queueing can reflect shared capacity pressure rather than a defect in each pipeline definition. Incorrect Answers A:For a production workload shows frequent retries after transient source failures, Monitor retry counts and failure categories separately from eventual success can be justified because high retry rates can threaten SLAs even when the final run status is green; for this scenario involving the team cannot explain why multiple pipeline runs wait in queue, the targeted response is Review capacity utilization, activity concurrency and queueing indicators. B:For this requirement of the team cannot explain why multiple pipeline runs wait in queue, Increase every scheduled job's concurrency to the maximum without observing capacity would be unsafe or ineffective because more simultaneous work can worsen contention and queuing; apply Review capacity utilization, activity concurrency and queueing indicators instead. D:The option Track refresh duration by query and compare source-row volumes applies to the separate issue that the slowest Dataflow Gen2 query varies with month-end volume, because performance baselines should be normalized to actual input size; the current condition is the team cannot explain why multiple pipeline runs wait in queue, which calls for Review capacity utilization, activity concurrency and queueing indicators.