- 131 Views
- 1 replies
- 1 kudos
Learning Path for Spark Developer Associate
Hello Everyone,Happy for being a part of Virtual Journey !!Enrolled in Associate Spark Developer and completed learning path in Databricks Academy. Can anyone please confirm is completing learning path enough for obtaining 50% off voucher for certifi...
- 131 Views
- 1 replies
- 1 kudos
- 1 kudos
Hello @Bhavana_Y! To be eligible for the incentives, you’ll need to complete one of the pathways mentioned in the Learning Festival post. Based on your screenshot, it looks like you’ve completed all four modules of LEARNING PATHWAY 7: APACHE SPARK DE...
- 1 kudos
- 298 Views
- 4 replies
- 3 kudos
Resolved! deadlock occurs with use statement
When issuing a query from Informatica using a Delta connection, the statement use catalog_name.schema_name is executed first. At that time, the following error appeared in the query history:Query could not be scheduled: (conn=5073499)Deadlock found w...
- 298 Views
- 4 replies
- 3 kudos
- 3 kudos
I’ll try making adjustments on the Informatica side.Thank you for your help.
- 3 kudos
- 862 Views
- 8 replies
- 6 kudos
Resolved! DAB + DLT destroy fails due to ownership/permissions mismatch
Hi all,We are running into an issue with Databricks Asset Bundles (DAB) when trying to destroy a DLT pipeline. Setup is as follows:Two separate service principals:Deployment SP: used by Azure DevOps for deploying bundles.Run_as SP: used for running t...
- 862 Views
- 8 replies
- 6 kudos
- 6 kudos
We just released https://github.com/databricks/cli/releases/tag/v0.273.0 with a mitigation for this, the error should disappear if you upgrade. Please try and let us know how it goes. Terraform fix is in https://github.com/databricks/terraform-provid...
- 6 kudos
- 114 Views
- 1 replies
- 0 kudos
Serverless - can't parallelize UDF in applyInPandas
HI allServerless V3 solved an error of mismatching python versions between driver and worker which I had on V2 (can't remember the exact wording).So I'd been running this on classic compute so far.Today I tried on serverless to a partial success - un...
- 114 Views
- 1 replies
- 0 kudos
- 0 kudos
I was wrong in interpreting the results. threading.get_native_id() does not work on serverless as on classic, so different threads return the same ID. The time it takes to execute the test is obviously less than 40 seconds, if it was running on a sin...
- 0 kudos
- 160 Views
- 2 replies
- 1 kudos
Spark Streaming Loading 1kto 5k rows only delta table
Hi Team,I have 4-5 millions of files in s3 files around 1.5gb data only with 9 million records, when i try to use autoloader to read the data using read stream and writing to delta table the processing is taking too much time, it is loading from 1k t...
- 160 Views
- 2 replies
- 1 kudos
- 1 kudos
@bunny1174 It is a common issue that small files gets created during streaming. Since you are using delta file format, I would suggest two solutions,1. try using Liquid clustering. This does auto compact of small files into a bigger chuck mostly of 1...
- 1 kudos
- 549 Views
- 9 replies
- 4 kudos
Flattening the json in databricks
I have chatbot data I read adls json file in databricks and i stored the output in dataframeIn that table two columns contains json data but the data type is string1.content2.metadata Now i have to flatten the.data but i am not getting how to do tha...
- 549 Views
- 9 replies
- 4 kudos
- 4 kudos
@szymon_dybczak your solution was crisp.@SuMiT1 since you have mentioned your json is dynamic, get one of your json body into a variable. json_body = df.select("content").take(1).collect(0)then get the schema of the json,schema = schema_of_json(json_...
- 4 kudos
- 188 Views
- 2 replies
- 2 kudos
Reading snappy.parquet
I stored a dataframe as delta in the catalog. It created multiple folders with snappy.parquet files. Is there a way to read these snappy.parquet files.it reads with pandas but with spark it gives error "incompatible format"
- 188 Views
- 2 replies
- 2 kudos
- 2 kudos
@Hritik_Moon Try to read the file as delta. path/delta_file_name/- parquet files- delta_log/since you are using spark, use this, spark.read.format("delta").load("path/delta_file_name").Delta internally stores the data as parquet and delta log contain...
- 2 kudos
- 309 Views
- 6 replies
- 8 kudos
Stop Cache in free edition
Hello,I am using databricks free edition, is there a way to turn off IO caching.I am trying to learn optimization and cant see any difference in query run time with caching enabled.
- 309 Views
- 6 replies
- 8 kudos
- 8 kudos
@Hritik_Moon 1. check if your data is cached, this you can see in sparkUI > storage tab.2. if it is not cached, try to add a action statement after you cache. eg : df.count(). Data is cached with the first action statement it encounters. Now check in...
- 8 kudos
- 2897 Views
- 8 replies
- 2 kudos
Databricks Job cluster for continuous run
Hi AllI am having situation where I wanted to run job as continuous trigger by using job cluster, cluster terminating and re-creating in every run within continuous trigger.I just wanted two know if we have any option where I can use same job cluster...
- 2897 Views
- 8 replies
- 2 kudos
- 2 kudos
This is a great initiative! As a data engineer, I always appreciate learning new optimization strategies. Recently, I stumbled upon Monkey Mart while researching resource-efficient architectures—funny how inspiration comes from unexpected places. Loo...
- 2 kudos
- 1802 Views
- 1 replies
- 1 kudos
Comparing Databricks Serverless Warehouse with Snowflake Virtual Warehouse for specific query
Hey,I would like to compare the runtime of one specific query by running it on Databricks Serverless Warehouse and Snowflake Virtual Warehouse.I create table with the exact same structure with the exact same dataset in both Warehouses.the dataset if ...
- 1802 Views
- 1 replies
- 1 kudos
- 1 kudos
You’re running into a Databricks SQL results delivery limit—the UI (and even “Download results”) isn’t meant to stream 1.5M × (id, name, 5,000-double array) back to your browser. That’s why SELECT * “works” on Snowflake’s console but not in the DBS...
- 1 kudos
- 130 Views
- 1 replies
- 1 kudos
DDL script to upper environment
I have multiple databases created in unity catalog in a DEV databricks workspace, I used databricks UI/notebook and ran scripts to do it. Now, I want to have those databases in QA and PROD workspaces as well. What is the best way to run those DDLs in...
- 130 Views
- 1 replies
- 1 kudos
- 1 kudos
Hi @KKo ,The simplest way is to have a parametrized notebook which you can pass a name of your catalog as your parameter. Then you can use that parameter to prepare appropriate SQL statements responsible for creating catalogs/schemas/tables.Alternati...
- 1 kudos
- 54986 Views
- 47 replies
- 25 kudos
Resolved! Cannot sign in at databricks partner-academy portal
Hi thereI have used my company email to register an account for customer-academy.databricks.com a while back. Now what I need to do is create an account with partner-academy.databricks.com using my company email too.However when I register at partner...
- 54986 Views
- 47 replies
- 25 kudos
- 222 Views
- 3 replies
- 1 kudos
Serverless environment not respecting environment spec on run_job_task
When running a job via a `run_job_task`, the job triggered is not using the specified serverless environment. I've configured my job to use serverless `environment_version` "3" with a dependency built into my workspace, but whenever I run the job, it...
- 222 Views
- 3 replies
- 1 kudos
- 1 kudos
@elliottatreef Can you try to set the Environment version on the source notebook and then trigger the job?On notebook -> Serverless -> configuration -> Environment version drop down. Then, in your job, making sure it’s assigning to the Serverless com...
- 1 kudos
- 272 Views
- 4 replies
- 5 kudos
Resolved! Python Wheel in Serverless Job in DAB
Hey,I am trying to run a job with serverless compute, that runs python scripts.I need the paramiko package to get my scripts to work. I managed to get it working by doing:environments:- environment_key: default# Full documentation of this spec can be...
- 272 Views
- 4 replies
- 5 kudos
- 5 kudos
Hi @georgemichael40 ,Put your whl file in the volume and then you can reference it in following way in your DAB file:dependencies: - " /Volumes/workspace/default/my_volume/hellopkg-0.0.1-py3-none-any.whl"https://docs.databricks.com/aws/en/compute/s...
- 5 kudos
- 8743 Views
- 5 replies
- 3 kudos
Can we use multiple git repos for a job running multiple tasks?
I have a job running multiple tasks :Task 1 runs a machine learning pipeline from git repo 1Task 2 runs an ETL pipeline from git repo 1Task 2 is actually a generic pipeline and should not be checked in repo 1, and will be made available in another re...
- 8743 Views
- 5 replies
- 3 kudos
- 3 kudos
Had this same problem. Fix was to have two workflows with no triggers, each pointing to the respective git repo. Then setup a 3rd workflow with appropriate triggers/schedule which calls the first 2 workflows. A workflow can run other workflows.
- 3 kudos
| User | Count |
|---|---|
| 1616 | |
| 790 | |
| 469 | |
| 349 | |
| 287 |
