Question 350 A global retailer runs large PySpark joins in a Fabric notebook over a fact table and small dimensions. Hundreds of unnecessary fields flow through an expensive join. Which action best addresses the observed Fabric behavior? Evaluate caching the reused DataFrame when memory and reuse justify it Project only required columns before the join Repartition the entire dataset into exactly one partition before every join Evaluate a broadcast join for the small reference table Explanation Correct Answer B:Column pruning reduces shuffle width, serialization and memory demand. Incorrect Answers A:For the Spark job repeatedly opens the same remote input in several branches, Evaluate caching the reused DataFrame when memory and reuse justify it can be justified because persisting genuinely reused intermediate data can avoid repeated recomputation but requires capacity analysis; for this scenario involving hundreds of unnecessary fields flow through an expensive join, the targeted response is Project only required columns before the join. C:Choosing Repartition the entire dataset into exactly one partition before every join would not satisfy the case condition (hundreds of unnecessary fields flow through an expensive join), because a single partition removes distributed parallelism and can overload one executor; Project only required columns before the join preserves the intended result. D:The option Evaluate a broadcast join for the small reference table applies to the separate issue that a large shuffle dominates runtime and the dimension truly fits in executor memory, because broadcasting a safe-sized dimension can avoid shuffling the large fact dataset; the current condition is hundreds of unnecessary fields flow through an expensive join, which calls for Project only required columns before the join.
Question 351 A research consortium sets up Fabric workspaces for experiments using sensitive genomics records. Analysts want to know whether an object is a managed table or a file shortcut. How should the team implement this requirement? Document the effective OneLake configuration and validate read/write behavior with limited test identities Treat every OneLake shortcut as a guaranteed local, unrestricted replica of its target Inspect the lakehouse Tables and Files structure plus the shortcut's actual target Verify source location and residency requirements before creating the OneLake shortcut Explanation Correct Answer C:A shortcut is a reference to another path, not a copy of source data into the consumer workspace. Incorrect Answers A:Although Document the effective OneLake configuration and validate read/write behavior with limited test identities fits the separate issue that a workspace storage setting changes before a sensitive ingestion test because a configuration change is not evidence of acceptable data access until representative reader and writer paths are tested, this case concerns analysts want to know whether an object is a managed table or a file shortcut and should be resolved with Inspect the lakehouse Tables and Files structure plus the shortcut's actual target. B:Choosing Treat every OneLake shortcut as a guaranteed local, unrestricted replica of its target would not satisfy the case condition (analysts want to know whether an object is a managed table or a file shortcut), because shortcut semantics and target authorization can differ from copying data into a new lakehouse; Inspect the lakehouse Tables and Files structure plus the shortcut's actual target preserves the intended result. D:Verify source location and residency requirements before creating the OneLake shortcut is useful when a proposed shortcut would refer to data stored in an unapproved geography, since a logical OneLake reference can still access data governed by the source's residency and security rules; however, the actual requirement is analysts want to know whether an object is a managed table or a file shortcut, which calls for Inspect the lakehouse Tables and Files structure plus the shortcut's actual target.
Question 352 A global retailer deploys Fabric Data Factory pipelines to stages with different data sources. A release engineer needs to know which pipeline version last reached production. Which solution is the most defensible for this case? Copy all test credentials into production connection definitions without review Assign workspaces to Fabric deployment pipeline stages with controlled promotion Retain deployment history linked to source branch and commit identifier Validate target-specific connection mappings and deployment rules Explanation Correct Answer C:Auditability depends on versioned promotion evidence, not filename labels. Incorrect Answers A:Choosing Copy all test credentials into production connection definitions without review would not satisfy the case condition (a release engineer needs to know which pipeline version last reached production), because environment isolation protects production sources and secrets from test-level access; Retain deployment history linked to source branch and commit identifier preserves the intended result. B:The option Assign workspaces to Fabric deployment pipeline stages with controlled promotion applies to the separate issue that developers want a repeatable development-to-test-to-production process, because stage association makes item comparison and planned promotion repeatable; the current condition is a release engineer needs to know which pipeline version last reached production, which calls for Retain deployment history linked to source branch and commit identifier. D:The action Validate target-specific connection mappings and deployment rules solves a pipeline's destination points to the staging lakehouse after production deployment because a promoted pipeline still requires appropriate production destination bindings; it does not by itself solve a release engineer needs to know which pipeline version last reached production, whereas Retain deployment history linked to source branch and commit identifier does.
Question 353 A banking data platform processes payment events from regulated and nonregulated business divisions. A warehouse query executes under an owner identity rather than the caller's identity. Which troubleshooting or configuration step is most appropriate? Grant a read-only user full workspace Admin just to enable one folder write Reconcile effective OneLake role-combination behavior before relying on the restrictions Inspect delegated versus user identity access and validate the applicable RLS controls Correlate producer and consumer identities, shortcut configuration and supported audit records Explanation Correct Answer C:Query identity is a material input to whether a data-level policy protects the end user. Incorrect Answers A:Applying Grant a read-only user full workspace Admin just to enable one folder write when a warehouse query executes under an owner identity rather than the caller's identity would introduce a defect because broad workspace administration is not necessary for a narrowly scoped write requirement; a direct solution is Inspect delegated versus user identity access and validate the applicable RLS controls. B:Reconcile effective OneLake role-combination behavior before relying on the restrictions is useful when multiple roles grant overlapping columns and differing row predicates, since column and row restrictions can interact differently across engines and must be tested; however, the actual requirement is a warehouse query executes under an owner identity rather than the caller's identity, which calls for Inspect delegated versus user identity access and validate the applicable RLS controls. D:For the bank needs audit proof that sensitive payment data was accessed through a shortcut, Correlate producer and consumer identities, shortcut configuration and supported audit records can be justified because a logical shortcut access can traverse two authorization scopes and requires end-to-end evidence; for this scenario involving a warehouse query executes under an owner identity rather than the caller's identity, the targeted response is Inspect delegated versus user identity access and validate the applicable RLS controls.
Question 354 An e-commerce retailer orchestrates daily batch transformations and occasional ad hoc data correction in Fabric. A five-step load must run in order and stop if validation fails. Which design decision most directly meets the requirement? Choose Dataflow Gen2 for the supported visual ingestion and transformation steps Model the dependencies and failure paths in a Fabric Data Factory pipeline Put every workflow decision into a single fixed notebook cell with no run metadata Execute a reviewed Fabric notebook activity with the required lakehouse environment Explanation Correct Answer B:Pipelines coordinate ordered tasks and conditional execution across different Fabric items. Incorrect Answers A:Choose Dataflow Gen2 for the supported visual ingestion and transformation steps is useful when business analysts need reusable visual Power Query transforms without writing distributed code, since dataflow Gen2 is suited to Power Query-based preparation, not full cross-system orchestration semantics; however, the actual requirement is a five-step load must run in order and stop if validation fails, which calls for Model the dependencies and failure paths in a Fabric Data Factory pipeline. C:For this requirement of a five-step load must run in order and stop if validation fails, Put every workflow decision into a single fixed notebook cell with no run metadata would be unsafe or ineffective because monolithic ad hoc execution obscures dependencies, scheduling and recovery evidence; apply Model the dependencies and failure paths in a Fabric Data Factory pipeline instead. D:Although Execute a reviewed Fabric notebook activity with the required lakehouse environment fits the separate issue that data scientists need custom PySpark logic on a large Delta dataset because spark notebooks support code-heavy distributed transformations that visual Dataflows need not express, this case concerns a five-step load must run in order and stop if validation fails and should be resolved with Model the dependencies and failure paths in a Fabric Data Factory pipeline.
Question 355 An airline brings flight status events into Fabric from an operational event feed. Flight changes have the same timestamp but increasing source sequence numbers. What should the data engineer change first? Use the authoritative source sequence to order updates Upsert by flight identifier and source version rather than unconditional append Choose the alphabetically last flight status instead of the newest source event Maintain separate versioned event history and a current-state projection Explanation Correct Answer A:A sequence field can disambiguate changes that share coarse timestamps. Incorrect Answers B:For only previously unseen flights should be inserted while changed statuses update existing rows, Upsert by flight identifier and source version rather than unconditional append can be justified because change-aware merge maintains one current row per flight when the source revises its status; for this scenario involving flight changes have the same timestamp but increasing source sequence numbers, the targeted response is Use the authoritative source sequence to order updates. C:Choosing Choose the alphabetically last flight status instead of the newest source event would not satisfy the case condition (flight changes have the same timestamp but increasing source sequence numbers), because lexicographic sorting has no reliable relationship to event chronology; Use the authoritative source sequence to order updates preserves the intended result. D:Option Maintain separate versioned event history and a current-state projection would focus on the separate issue that the business needs both current status and an immutable audit of all transitions because a single overwriting current table cannot also serve as a complete history of status transitions, not the current requirement that flight changes have the same timestamp but increasing source sequence numbers; the appropriate remedy is Use the authoritative source sequence to order updates.
Question 356 An advertising agency builds a recurring Fabric Data Factory Copy pipeline from a partner API. The destination must use the right connector and authentication rather than a hardcoded test token. Which action best addresses the observed Fabric behavior? Apply bounded retry and throughput controls that honor the source rate limit Configure the supported Copy activity connection with protected credentials Use supported pagination or controlled page iteration with completion checks Put the partner's production bearer token in plaintext pipeline run descriptions Explanation Correct Answer B:Connection configuration and managed authentication support repeatable production extraction. Incorrect Answers A:For the source limits requests per minute and the pipeline receives rate-limit errors, Apply bounded retry and throughput controls that honor the source rate limit can be justified because aggressive unbounded requests can worsen throttling and missing data; for this scenario involving the destination must use the right connector and authentication rather than a hardcoded test token, the targeted response is Configure the supported Copy activity connection with protected credentials. C:Option Use supported pagination or controlled page iteration with completion checks would focus on the separate issue that the partner API paginates results and a single request omits most entries because all response pages must be extracted to avoid silent record loss, not the current requirement that the destination must use the right connector and authentication rather than a hardcoded test token; the appropriate remedy is Configure the supported Copy activity connection with protected credentials. D:The option Put the partner's production bearer token in plaintext pipeline run descriptions fails to meet the destination must use the right connector and authentication rather than a hardcoded test token, given that operational logs and comments are not approved secret storage; Configure the supported Copy activity connection with protected credentials is the correct scope of action.
Question 357 A multi-tenant SaaS platform receives application logs in a Real-Time Intelligence stream. The Eventhouse should retain short-term searchable log events for operational triage. How should the team implement this requirement? Give tenants a shared KQL login with unrestricted cross-tenant table access Use native KQL ingestion with an approved retention and access policy Apply query acceleration with a cache period reflecting actual hot data Use a supported OneLake shortcut with external-table KQL access Explanation Correct Answer B:Eventhouse supports event-oriented searches and configurable operational data management. Incorrect Answers A:Choosing Give tenants a shared KQL login with unrestricted cross-tenant table access would not satisfy the case condition (the Eventhouse should retain short-term searchable log events for operational triage), because tenant isolation requires enforced identity and row or source boundaries; Use native KQL ingestion with an approved retention and access policy preserves the intended result. C:The option Apply query acceleration with a cache period reflecting actual hot data applies to the separate issue that historical KQL queries are slow and mostly access the latest few days, because caching the recent external working set can reduce repeated storage scans; the current condition is the Eventhouse should retain short-term searchable log events for operational triage, which calls for Use native KQL ingestion with an approved retention and access policy. D:Use a supported OneLake shortcut with external-table KQL access is useful when older logs in Delta should be queried without another daily copy job, since referenced historical data can complement native events when query performance is acceptable; however, the actual requirement is the Eventhouse should retain short-term searchable log events for operational triage, which calls for Use native KQL ingestion with an approved retention and access policy.
Question 358 An enterprise stores large Delta tables in a Fabric lakehouse and orchestrates maintenance. A model refresh begins before maintenance or data load completes. Which solution is the most defensible for this case? Delete all Delta transaction logs to reduce monitoring noise Change the orchestration dependency to wait for a verified successful load Monitor maintenance failures and Delta file-count trends with clear thresholds Compare per-partition source keys and target commit evidence Explanation Correct Answer B:Refreshing a partially updated table can expose inconsistent data. Incorrect Answers A:Applying Delete all Delta transaction logs to reduce monitoring noise when a model refresh begins before maintenance or data load completes would introduce a defect because delta log removal would compromise table consistency and recovery; a direct solution is Change the orchestration dependency to wait for a verified successful load. C:Monitor maintenance failures and Delta file-count trends with clear thresholds is useful when operations wants alerts for failed table maintenance and steadily growing file counts, since file accumulation is an operational symptom that needs observability beyond a single job status; however, the actual requirement is a model refresh begins before maintenance or data load completes, which calls for Change the orchestration dependency to wait for a verified successful load. D:The action Compare per-partition source keys and target commit evidence solves a nightly notebook succeeds but Delta output has missing expected partitions because spark execution success does not establish complete partition coverage; it does not by itself solve a model refresh begins before maintenance or data load completes, whereas Change the orchestration dependency to wait for a verified successful load does.
Question 359 A delivery company uses Eventstream to route messages from several queues. One filter drops all valid messages due to a wrongly typed condition. Which troubleshooting or configuration step is most appropriate? Drop messages whose structure changed without retaining error or schema evidence Inspect filter predicate types and compare sample event payloads Correct event schema and destination field mapping Review throughput limits, capacity and sink ingestion metrics before scaling Explanation Correct Answer B:A filter can intentionally exclude every event when a field type or value is wrong. Incorrect Answers A:The option Drop messages whose structure changed without retaining error or schema evidence fails to meet one filter drops all valid messages due to a wrongly typed condition, given that silent discard hides source-contract regressions and prevents safe recovery; Inspect filter predicate types and compare sample event payloads is the correct scope of action. C:The action Correct event schema and destination field mapping solves a destination receives messages but key fields are null because partial data delivery can still be an ingestion defect when fields fail conversion; it does not by itself solve one filter drops all valid messages due to a wrongly typed condition, whereas Inspect filter predicate types and compare sample event payloads does. D:For burst traffic causes a growing backlog and late analytics results, Review throughput limits, capacity and sink ingestion metrics before scaling can be justified because backpressure requires evidence of where events queue rather than indiscriminate restarts; for this scenario involving one filter drops all valid messages due to a wrongly typed condition, the targeted response is Inspect filter predicate types and compare sample event payloads.
Question 360 A municipal authority queries a lakehouse SQL analytics endpoint backed by Delta tables. The underlying Delta table contains many tiny files after repeated merges. Which design decision most directly meets the requirement? Delete old Parquet files directly in OneLake without consulting Delta transaction metadata Check maintenance completion and endpoint synchronization status Run appropriate Delta compaction on the source lakehouse table Inspect query statistics and execution plan for the affected columns Explanation Correct Answer C:File compaction improves read efficiency in the underlying storage, not only Spark-specific queries. Incorrect Answers A:Delete old Parquet files directly in OneLake without consulting Delta transaction metadata would not satisfy the underlying Delta table contains many tiny files after repeated merges because raw file deletion can break live Delta table versions and query consistency; the defensible response is Run appropriate Delta compaction on the source lakehouse table. B:The action Check maintenance completion and endpoint synchronization status solves a consumer expects row-level data freshness immediately after an asynchronous maintenance operation because asynchronous work and metadata sync can create observable delays despite a submitted request; it does not by itself solve the underlying Delta table contains many tiny files after repeated merges, whereas Run appropriate Delta compaction on the source lakehouse table does. D:Although Inspect query statistics and execution plan for the affected columns fits the separate issue that the query optimizer chooses a poor join plan for heavily modified data because table metadata and cardinality estimates influence warehouse and endpoint query planning, this case concerns the underlying Delta table contains many tiny files after repeated merges and should be resolved with Run appropriate Delta compaction on the source lakehouse table.