Question 140 A commercial airline processes many small Fabric Dataflow Gen2 and pipeline loads each hour. Dataflow Gen2 refresh repeatedly processes all historical rows despite a small change set. Which action best addresses the observed Fabric behavior? Evaluate a supported incremental or partitioned source load strategy Overwrite source history during dataflow tuning to avoid reading large input Combine compatible small loads into efficient batches with bounded orchestration Bound concurrency and honor connector rate limits using measured retries Explanation Correct Answer A:Matching extraction to change volume reduces unnecessary transformation work. Incorrect Answers B:For this requirement of dataflow Gen2 refresh repeatedly processes all historical rows despite a small change set, Overwrite source history during dataflow tuning to avoid reading large input would be unsafe or ineffective because performance changes should preserve source data and business correctness; apply Evaluate a supported incremental or partitioned source load strategy instead. C:Option Combine compatible small loads into efficient batches with bounded orchestration would focus on the separate issue that multiple tiny pipeline runs spend more time starting than moving data because reducing per-run overhead can improve throughput without changing business semantics, not the current requirement that dataflow Gen2 refresh repeatedly processes all historical rows despite a small change set; the appropriate remedy is Evaluate a supported incremental or partitioned source load strategy. D:The option Bound concurrency and honor connector rate limits using measured retries applies to the separate issue that increasing parallel refresh count causes source API throttling, because more simultaneous calls can reduce rather than improve effective throughput under throttling; the current condition is dataflow Gen2 refresh repeatedly processes all historical rows despite a small change set, which calls for Evaluate a supported incremental or partitioned source load strategy.
Question 141 An education platform separates interactive notebooks from automated nightly data products. A new runtime release changes default execution behavior for the training pipeline. How should the team implement this requirement? Store every dataset password as a Spark configuration string in shared notebook output Inspect the run's effective environment, runtime and session configuration Attach a production-tested Fabric environment to the scheduled notebook Validate the intended Spark runtime against a locked regression dataset before switching Explanation Correct Answer D:Fixed-data output comparisons reveal semantic regressions that startup checks cannot detect. Incorrect Answers A:For this requirement of a new runtime release changes default execution behavior for the training pipeline, Store every dataset password as a Spark configuration string in shared notebook output would be unsafe or ineffective because shared session settings and logs are not safe secret storage; apply Validate the intended Spark runtime against a locked regression dataset before switching instead. B:Option Inspect the run's effective environment, runtime and session configuration would focus on the separate issue that a team lead must identify whether a failed notebook used the right Spark pool and environment because debugging should start from the settings that actually executed, not a later edited workspace baseline, not the current requirement that a new runtime release changes default execution behavior for the training pipeline; the appropriate remedy is Validate the intended Spark runtime against a locked regression dataset before switching. C:The option Attach a production-tested Fabric environment to the scheduled notebook applies to the separate issue that nightly notebooks need stable Python dependencies that differ from student experiments, because an explicit environment avoids accidental dependence on packages installed interactively by another user; the current condition is a new runtime release changes default execution behavior for the training pipeline, which calls for Validate the intended Spark runtime against a locked regression dataset before switching.
Question 142 A subscription service has integrated Fabric notebooks and lakehouses with a source repository. A notebook references a workspace-specific lakehouse ID embedded in a cell. Which solution is the most defensible for this case? Parameterize the environment-specific lakehouse binding and test after stage promotion Compare both directions and reconcile before performing a workspace update Preserve reviewed source revisions and repeatable deployment configuration Assume Git integration automatically backs up all OneLake source files and credentials Explanation Correct Answer A:Hard-coded development IDs can make production notebooks read the wrong item. Incorrect Answers B:The option Compare both directions and reconcile before performing a workspace update applies to the separate issue that an engineer changes a notebook in the portal while another updates Git, because a Git-to-workspace sync may overwrite an unsaved or divergent portal edit; the current condition is a notebook references a workspace-specific lakehouse ID embedded in a cell, which calls for Parameterize the environment-specific lakehouse binding and test after stage promotion. C:Preserve reviewed source revisions and repeatable deployment configuration is useful when production item definitions must be recreated for disaster recovery, since version-controlled metadata improves restoration but still requires data and secrets recovery separately; however, the actual requirement is a notebook references a workspace-specific lakehouse ID embedded in a cell, which calls for Parameterize the environment-specific lakehouse binding and test after stage promotion. D:Assume Git integration automatically backs up all OneLake source files and credentials would not satisfy a notebook references a workspace-specific lakehouse ID embedded in a cell because definition versioning is not a replacement for storage backup or secret management; the defensible response is Parameterize the environment-specific lakehouse binding and test after stage promotion.
Question 143 A museum analytics team publishes a public dataset beside restricted donor information in Fabric. Visitors should access a curated exhibition count without opening the donor lakehouse. Which troubleshooting or configuration step is most appropriate? Check dynamic data masking definition and whether the test principal has UNMASK privilege Share a limited derived output and keep donor raw-data items privately authorized Apply appropriate column-level security to the donor dataset Hide an identifier column in Power BI and declare all underlying SQL access secure Explanation Correct Answer B:A published aggregate should not imply permission to the confidential source tables. Incorrect Answers A:The option Check dynamic data masking definition and whether the test principal has UNMASK privilege applies to the separate issue that a general user sees exact monetary values where a masked value is expected, because masking effectiveness depends on both predicate and execution identity; the current condition is visitors should access a curated exhibition count without opening the donor lakehouse, which calls for Share a limited derived output and keep donor raw-data items privately authorized. C:The action Apply appropriate column-level security to the donor dataset solves a named donor column is required only for the fundraising director because column authorization is more enforceable than hiding a field in one report's visual settings; it does not by itself solve visitors should access a curated exhibition count without opening the donor lakehouse, whereas Share a limited derived output and keep donor raw-data items privately authorized does. D:For this requirement of visitors should access a curated exhibition count without opening the donor lakehouse, Hide an identifier column in Power BI and declare all underlying SQL access secure would be unsafe or ineffective because visualization hiding cannot replace backend data permissions; apply Share a limited derived output and keep donor raw-data items privately authorized instead.
Question 144 A regional authority processes traffic-camera metadata in a nightly analytics orchestration. The next stage must choose a branch based on a row-count validation outcome. Which design decision most directly meets the requirement? Use idempotent write keys and persisted execution checkpoints Use a random failure branch to distribute processing without checking row counts Use an If Condition expression based on the validated activity output Configure a failure dependency and maintain the upstream error context Explanation Correct Answer C:Conditional branching turns a measured quality result into an explicit orchestration decision. Incorrect Answers A:Use idempotent write keys and persisted execution checkpoints is useful when operators need to avoid duplicating a destination partition on retry, since retry safety must be implemented in the transformation or sink, not inferred from the orchestrator; however, the actual requirement is the next stage must choose a branch based on a row-count validation outcome, which calls for Use an If Condition expression based on the validated activity output. B:Use a random failure branch to distribute processing without checking row counts would not satisfy the next stage must choose a branch based on a row-count validation outcome because business validation conditions should be deterministic and evidence-driven; the defensible response is Use an If Condition expression based on the validated activity output. D:Although Configure a failure dependency and maintain the upstream error context fits the separate issue that an error-handling task must execute only when the SQL load fails because conditional failure paths prevent alerts from being raised for successful work, this case concerns the next stage must choose a branch based on a row-count validation outcome and should be resolved with Use an If Condition expression based on the validated activity output.
Question 145 A bank processes account status changes using a source that exposes database log CDC. CDC events can arrive twice after connector failover. What should the data engineer change first? Establish a consistent snapshot and change-position handoff Enforce event-position idempotency in the target application step Verify the persisted source offset and reconcile a bounded missed-event window Ignore delete operations because they use less storage than inserts Explanation Correct Answer B:Duplicate commit positions should not apply the same source mutation twice. Incorrect Answers A:The action Establish a consistent snapshot and change-position handoff solves an initial snapshot must not race with the live CDC feed because the initial-state and change-stream boundaries must overlap without gaps or double application; it does not by itself solve cDC events can arrive twice after connector failover, whereas Enforce event-position idempotency in the target application step does. C:Although Verify the persisted source offset and reconcile a bounded missed-event window fits the separate issue that a CDC connector starts at an incorrect log offset after maintenance because correctness depends on continuity across the source change stream, not merely connector uptime, this case concerns cDC events can arrive twice after connector failover and should be resolved with Enforce event-position idempotency in the target application step. D:Applying Ignore delete operations because they use less storage than inserts when cDC events can arrive twice after connector failover would introduce a defect because missing tombstones can leave closed or removed accounts incorrectly active; a direct solution is Enforce event-position idempotency in the target application step.
Question 146 A logistics company transforms nested JSON shipments into a curated Delta table with PySpark. Each shipment contains an array of individual packages that must become separate rows. Which action best addresses the observed Fabric behavior? Explode the entire parent shipment row four times without preserving package identity Parse and normalize timestamps with explicit timezone assumptions Use explode on the package array while retaining its parent shipment key Evaluate a broadcast join when the reference table fits safe executor memory limits Explanation Correct Answer C:Exploding preserves package-level grain for downstream scanning and aggregation. Incorrect Answers A:For this requirement of each shipment contains an array of individual packages that must become separate rows, 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 Use explode on the package array while retaining its parent shipment key instead. B:Although Parse and normalize timestamps with explicit timezone assumptions fits 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, this case concerns each shipment contains an array of individual packages that must become separate rows and should be resolved with Use explode on the package array while retaining its parent shipment key. D:The option Evaluate a broadcast join when the reference table fits safe executor memory limits applies to the separate issue that a small lookup table enriches a very large shipments DataFrame, because broadcasting a genuinely small dimension can avoid shuffling a massive fact table; the current condition is each shipment contains an array of individual packages that must become separate rows, which calls for Use explode on the package array while retaining its parent shipment key.
Question 147 A weather analytics service uses KQL in Eventhouse to examine severe storms. A query should exclude invalid negative wind speeds before aggregation. How should the team implement this requirement? Use arg_max(eventTime, *) by stationId with valid event-time fields Choose the alphabetically last timestamp as proof of the newest measurement Apply a where predicate based on the validated measurement domain Join the stream aggregates to a keyed threshold lookup with explicit region and sensor type Explanation Correct Answer C:Early filtering removes invalid records without fabricating plausible values. Incorrect Answers A:Although Use arg_max(eventTime, *) by stationId with valid event-time fields fits the separate issue that the analyst needs only the most recent measurement per weather station because kQL arg_max returns the row associated with the maximum ordering expression for each station, this case concerns a query should exclude invalid negative wind speeds before aggregation and should be resolved with Apply a where predicate based on the validated measurement domain. B:Applying Choose the alphabetically last timestamp as proof of the newest measurement when a query should exclude invalid negative wind speeds before aggregation would introduce a defect because lexical sorting of mixed timestamp strings can be unreliable without typed datetime conversion; a direct solution is Apply a where predicate based on the validated measurement domain. D:Join the stream aggregates to a keyed threshold lookup with explicit region and sensor type is useful when the team needs to compare current readings against the prior approved weather threshold table, since joining thresholds on the right business keys prevents false alerts across incomparable stations; however, the actual requirement is a query should exclude invalid negative wind speeds before aggregation, which calls for Apply a where predicate based on the validated measurement domain.
Question 148 A logistics analytics team monitors simultaneous scheduled and event-based workflows. Engineers need an end-to-end event-to-report delay metric. Which solution is the most defensible for this case? Correlate source event time, destination commit and semantic refresh completion Identify trigger overlap and enforce deduplicated run admission or sink idempotency Use the existence of a file-event trigger as proof all files were processed once Review required dependency and completion semantics for all business-critical branches Explanation Correct Answer A:Overall latency spans source ingestion, transformation and serving availability. Incorrect Answers B:The option Identify trigger overlap and enforce deduplicated run admission or sink idempotency applies to the separate issue that two triggers launch the same incremental batch close together, because concurrent duplicate starts can produce conflicting writes without a stable business run key; the current condition is engineers need an end-to-end event-to-report delay metric, which calls for Correlate source event time, destination commit and semantic refresh completion. C:Use the existence of a file-event trigger as proof all files were processed once would not satisfy engineers need an end-to-end event-to-report delay metric because event triggers do not automatically enforce exactly-once destination writes; the defensible response is Correlate source event time, destination commit and semantic refresh completion. D:The action Review required dependency and completion semantics for all business-critical branches solves a pipeline reports success while one optional branch is still processing because pipeline success criteria must match the actual completeness contract; it does not by itself solve engineers need an end-to-end event-to-report delay metric, whereas Correlate source event time, destination commit and semantic refresh completion does.
Question 149 A scientific institute has Fabric PySpark notebooks that fail during large joins. A Delta write fails due to a competing transaction. Which troubleshooting or configuration step is most appropriate? Correct the attached lakehouse context and qualified table reference Inspect executor memory, join strategy and partition/skew evidence before tuning Disable Spark exception logging to prevent executors from running out of memory Review concurrent writes, transaction conflicts and retry or serialization design Explanation Correct Answer D:Delta transactional conflicts require safe concurrency handling rather than disabling consistency controls. Incorrect Answers A:The option Correct the attached lakehouse context and qualified table reference applies to the separate issue that a notebook references a table that was renamed in another workspace, because namespace or item reference mismatches can produce table-not-found errors despite healthy Spark compute; the current condition is a Delta write fails due to a competing transaction, which calls for Review concurrent writes, transaction conflicts and retry or serialization design. B:Inspect executor memory, join strategy and partition/skew evidence before tuning is useful when spark reports an out-of-memory error while joining a huge fact table, since a shuffle or oversized broadcast can exhaust executor memory independently of input file validity; however, the actual requirement is a Delta write fails due to a competing transaction, which calls for Review concurrent writes, transaction conflicts and retry or serialization design. C:For this requirement of a Delta write fails due to a competing transaction, Disable Spark exception logging to prevent executors from running out of memory would be unsafe or ineffective because removing diagnostics does not correct a failing join or library reference; apply Review concurrent writes, transaction conflicts and retry or serialization design instead.
Question 150 A research consortium uses PySpark to join highly skewed experimental samples. The DataFrame is used by four expensive downstream analyses. Which design decision most directly meets the requirement? Inspect skewed keys and evaluate salting or adaptive skew-join behavior when appropriate Review Spark adaptive execution and partition settings based on observed task sizes Persist the intermediate only when reuse and cache capacity justify it Disable adaptive execution solely because its configuration name contains the word adaptive Explanation Correct Answer C:Materialization can reduce repeated upstream work but memory may be more valuable for active shuffles. Incorrect Answers A:Inspect skewed keys and evaluate salting or adaptive skew-join behavior when appropriate is useful when one batch is dominated by a single experiment ID with millions of measurements, since a hot key can create one massive shuffle partition even with many available executors; however, the actual requirement is the DataFrame is used by four expensive downstream analyses, which calls for Persist the intermediate only when reuse and cache capacity justify it. B:The action Review Spark adaptive execution and partition settings based on observed task sizes solves a shuffle creates too many tiny post-shuffle tasks because appropriate partition sizes reduce scheduler overhead without sacrificing parallelism; it does not by itself solve the DataFrame is used by four expensive downstream analyses, whereas Persist the intermediate only when reuse and cache capacity justify it does. D:Applying Disable adaptive execution solely because its configuration name contains the word adaptive when the DataFrame is used by four expensive downstream analyses would introduce a defect because fabric runtimes enable AQE by default; changes should follow measured execution evidence; a direct solution is Persist the intermediate only when reuse and cache capacity justify it.