spark job definition
139 TopicsScaling up to down fabric capacity giving utilisation error.
Hello, I have upscale my fabric capacity to F32 from F8 because I want to process 400 gb of data so now I have completed my work on few minutes and then I have down scale fabric capacity from F32 to F8 but after scaling down it is giving error like your organization has used entire capacity no capacity available. How to resolve this i don't want to increase capacity to resolve this issue.56Views2likes7CommentsData pipeline is remaning into InProgress state
Hello, I have created data pipeline and in that i have only 1 notebook, but it is taking around 15-25 min average to run my pipeline and i am using F4 capacity. and i feel F4 is more then enough for it still why i am facing this issue Need help.143Views0likes4CommentsCU consumption spike when running 20 notebooks concurrently, scheduled daily (F-SKU capacity)
Hi everyone, I'm running into unpredictable Capacity Unit (CU) consumption and would appreciate some guidance from the community. Setup: Capacity type: F-SKU (Fabric capacity), Pay-as-you-go Schedule: Daily, automated trigger, planned to run continuously for 1 year Workload: 20 notebook files running concurrently in the same schedule Each notebook imports historical data with a date range of 3–10 years (daily granularity Looking at the Spark run duration chart in the Capacity Metrics App, most runs complete in a relatively short time taking 1-2 hours. Since this workload is meant to run daily, I want to make sure the setup is sustainable and cost-predictable before scaling it up long-term. Questions: What could cause this kind of duration spike when running notebooks with large historical data imports (3–10 years, daily data) concurrently? Does running 20 notebooks at the same time on a single F-SKU capacity cause resource contention that leads to this kind of unpredictable duration/CU spike? For a workload scheduled to run daily, are there best practices to keep CU consumption predictable and avoid recurring spikes — e.g., staggering start times, splitting the data import range, or adjusting Spark pool/session settings? Given the long-running nature of this schedule (1 year), would Reserved Capacity be more cost-effective than Pay-as-you-go for this kind of consistent daily workload? How can I proactively monitor which specific notebook/session is driving the spike, beyond what's shown in the Capacity Metrics App? Based on this workload pattern (20 concurrent notebooks, daily schedule, each importing 3–10 years of historical data), what F-SKU size would you recommend as a starting point? Is there a rule of thumb for estimating capacity size based on concurrent Spark sessions and data volume? Any insights on capacity sizing, concurrency limits, or scheduling strategy would be very helpful. Thanks in advance!47Views0likes3CommentsUpcoming DP-700 Free Voucher Opportunities
Hello everyone, I am currently preparing for the DP-700: Microsoft Fabric Data Engineer Associate certification. I noticed that the recent 100% voucher campaign has ended. Could you please let me know if there are any upcoming official Microsoft/Fabric Community events or campaigns offering free DP-700 exam vouchers? Thank you.70Views0likes1CommentAre Spark Jobs Supposed to Retry on Failure by Default?
My spark job in Fabric has the retry policy disabled (even if I enable it I can't set Max retry attempts to 0, this is the most disabled it gets). But the first time my .py file hits a "raise Exception", the job just restarts (the next time, it doesn't restart). I'm also pretty confident that sometimes after it retries, the entire log for the first pass is just gone. I only know b/c I have some messages being sent to an outside table, and what I see in there doesn't match up with what's actually in the job's log. Any ideas?Solved2.6KViews0likes6CommentsChoosing the Right Way to Run Python in Microsoft Fabric
Fabric gives us several ways to run Python, and at first they can look overlapping. In this post, I share the practical decision model I use to choose the right option based on execution mode, compute engine, and data access path. If you are code-first and want fewer wrong turns when moving from exploration to production, this guide is for you.446Views13likes3CommentsFabric Pipeline Performance
Hello Everyone, We have built a pipeline with a Notebook activity and a Switch activity. Under the Switch activity, we are calling 4 pipelines sequentially, and each pipeline in turn executes a notebook. Currently, when we execute the notebooks individually, each notebook completes in less than a minute. However, when the same notebooks are triggered through the pipeline, each execution takes around 4–5 minutes. As a result, the overall pipeline execution time has increased to approximately 15 minutes, whereas our expectation is to complete the entire process in under 5 minutes. Could you please provide some guidance or best practices to help improve the execution performance and reduce the overall pipeline runtime? ThanksSolved740Views0likes8CommentsNotebook does not stop in monitor
Dear community, i have a question: i've started a notebook. So far so good. And in visual studio it ends after 1 min. But in my monitor the notebook it is still marked as "In progress". And i cannot start another job. What is going on? Has somebody an idea? best regards MarkSolved923Views0likes12CommentsHistorical Backlog Snapshots in Microsoft Fabric - SQL vs PySpark
Recently, I worked on a historical backlog snapshot solution in Microsoft Fabric to support: Backlog aging (30/60/90+ days) PM and Manual Work Orders Historical trend reporting Large-scale datasets Our initial implementation used a SQL Stored Procedure with CROSS JOINs, multiple CASE conditions, and status-based filtering. While it delivered the required results, debugging and maintaining the logic became increasingly challenging as requirements evolved. After extensive troubleshooting, we moved the transformation logic to a PySpark Notebook. This allowed us to validate each transformation stage independently and quickly identify issues related to joins, filters, and business rules. Benefits observed: Step-by-step debugging and validation Better visibility into joins and filters Easier maintenance of business rules Improved scalability for larger datasets Key Takeaway SQL Stored Procedures are effective for many ETL scenarios. However, for historical snapshot reporting involving complex business logic and large datasets, PySpark provided greater flexibility, maintainability, and debugging capabilities. I'd be interested to hear how others have approached similar challenges in Fabric. How are others handling historical snapshot reporting in Microsoft Fabric? Are you using SQL, Spark Notebooks, Dataflows Gen2, or a hybrid approach?Solved893Views1like10CommentsHow to set the maximum number of application attempts?
Hi there, I'm wondering if there is a way to control the maximum number of application attempts for a spark job submitted via the Spark Job Definition? When an application fails, you can see it makes two attempts, then fails completely. I want to set this to only be a single attempt (it's a spark streaming job, and I want the whole application to fail after the first attempt). You can see an example of this below: I have tried to set spark.yarn.maxAttempts via the Spark environment: And through the job's environment tab in the history server you can see the setting has made it through to the app: However, in the same tab you can also see the ID is set to 2 on the second attempt, so it keeps making two attempts then failing completely: Are there any other settings that might be controlling this? Thanks420Views0likes4Comments