- 2145 Views
- 8 replies
- 0 kudos
inconsistent behavior with serverless sql: user is not an owner of table error with views
We get the following error with some basic views and not others when using serverless compute (from a notebook or from SQL Editor or from the Catalog Explorer). Views are simple select * from table x and underlying schemas/tables are using managed m...
- 2145 Views
- 8 replies
- 0 kudos
- 0 kudos
@ceceliac just a quick check, if you rerun the same query after it has initially failed, will it go through or still fail? if it runs fine, wait another 10-15mins and rerun it and share the outcome. So: 1.- Run it once, it will fail. 2.- Rerun it inm...
- 0 kudos
- 924 Views
- 1 replies
- 0 kudos
RESTORE deletes part of the delta table's history
Having a delta table with the history of 15 versions (see screenshot). After running the command:RESTORE TABLE hive_metastore.my_schema.my_table TO VERSION AS OF 6;And then running DESCRIBE HISTORY (see screenshot) it seems that a new version (RESTOR...
- 924 Views
- 1 replies
- 0 kudos
- 0 kudos
it's not. I haven't observed this behavior. According to the delta lake documentation "Using the restore command resets the table’s content to an earlier version, but doesn’t remove any data. It simply updates the transaction log to indicate that cer...
- 0 kudos
- 3902 Views
- 2 replies
- 1 kudos
Load data from Aurora to Databricks directly
Hi,Does anyone know how to link Aurora to Databricks directly and load data into Databricks automatically on a schedule without any third-party tools in the middle?
- 3902 Views
- 2 replies
- 1 kudos
- 1 kudos
AWS Aurora supports PostgreSQL or MySQL, did you try to connect using JDBC?url = f"jdbc:postgresql://{database_host}:{database_port}/{database_name}"remote_table = (spark.read.format("jdbc").option("driver", driver).option("url", url).option("dbtable...
- 1 kudos
- 3665 Views
- 4 replies
- 0 kudos
Resolved! Writing a small pyspark dataframe to a table is taking a very long time
My experience with Databricks pyspark up to this point has always been to execute a SQL query against existing Databricks tables, then write the resulting pyspark dataframe into a new table. For the first time, I am now getting data via an API which ...
- 3665 Views
- 4 replies
- 0 kudos
- 0 kudos
After reading the suggested documentation, I tried using the "Parse nested XML (from_xml and schema_of_xml)". I used this code from the doc: df = spark.createDataFrame([(8, xml_data)], ["number", "payload"]) schema = schema_of_xml(df.select("payload"...
- 0 kudos
- 3395 Views
- 2 replies
- 2 kudos
Serverless compute vs Job cluster
Hi Guys,For running the job with varying workload what should I use ? Serverless cluster or Job compute ?What are positives and negatives?(I'll be running my notebook from Azure data factory)
- 3395 Views
- 2 replies
- 2 kudos
- 2 kudos
It depends on cost, performance and startup time needed for your use-case.Serverless compute is usually preferred choice because of its fast startup time and dynamic scaling. However, if your workload is long-running and predictable, job compute with...
- 2 kudos
- 1139 Views
- 1 replies
- 1 kudos
Databricks Vs Fabric use case
Hi Team,We've noticed that for some use cases, customers are proposing a architecture with A) Fabric in the Gold layer and reporting in Azure Power BI, while using Databricks for the Bronze and Silver layers. However, we can also have the B) Gold lay...
- 1139 Views
- 1 replies
- 1 kudos
- 1 kudos
Gold layer in Databricks and connect to Power BI - this is a good option.However, If you need to use some of Fabric capabilities, because your team has preferences to use T-SQL, Direct Lake, Python notebooks, low-code tools like Data Factory. MS Fabr...
- 1 kudos
- 2639 Views
- 3 replies
- 2 kudos
OOM Issue in Streaming with foreachBatch()
I have a stateless streaming application that uses foreachBatch. This function executes between 10-400 times each hour based on custom logic. The logic within foreachBatch includes: collect() on very small DataFrames (a few megabytes) --> driver mem...
- 2639 Views
- 3 replies
- 2 kudos
- 2 kudos
Did you ever figure out what is causing the memory leak? We are experiencing a nearly identical issue where the memory gradually increases over time and OOM after a few days. I did track down this open bug ticket that states there is a memory leak ...
- 2 kudos
- 1566 Views
- 3 replies
- 1 kudos
Autoloader infering struct as a string when reading json data
Hi Everyone,Trying to read JSON files with autoloader is failing to infer the schema correctly, every nested or struct column is being inferred as a string. spark.readStream.format("cloudFiles") .option("cloudFiles.format", "json") .option("cloud...
- 1566 Views
- 3 replies
- 1 kudos
- 1 kudos
Hi @robertomatus ,You're right—it would be much better if we didn’t have to rely on workarounds. The reason AutoLoader infers schema differently from spark.read.json() is that it's optimized for streaming large-scale data efficiently. Unlike spark.re...
- 1 kudos
- 2185 Views
- 1 replies
- 0 kudos
Databricks vs snowflake use case comparision
Hi Databricks Team,We see Databricks and Snowflake as very close in terms of features. When trying to convince customers about Databricks' products, we would like to know the key comparisons between Databricks and Snowflake by use case.Regards,Phani
- 2185 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @Phani1, You can read these resources: https://www.databricks.com/databricks-vs-snowflake https://www.databricks.com/blog/2018/08/27/by-customer-demand-databricks-and-snowflake-integration.html
- 0 kudos
- 999 Views
- 2 replies
- 0 kudos
df.isEmpty() and df.fillna(0).isEmpty() throws error
In our code we usually use Single user cluster with 13.3 LTS with Spark 3.4.1 when loading data from delta table to Azure SQL Hyperscale, and we did not experience any issues, but starting last week our pipeline has been failing with the following er...
- 999 Views
- 2 replies
- 0 kudos
- 0 kudos
Hi @Alberto_Umana ,Yes I checked and did not see any other information. We are using Driver: Standard_DS5_v2 · Workers: Standard_E16a_v4 · 1-6 workers, at the stage when the pipeline fails the shuffle information was :Shuffle Read Size / Records: 257...
- 0 kudos
- 874 Views
- 4 replies
- 0 kudos
- 874 Views
- 4 replies
- 0 kudos
- 0 kudos
It looks like your completion email was distributed on Feb 04, but I will DM you the certification discount code again for your reference
- 0 kudos
- 535 Views
- 1 replies
- 0 kudos
Resolved! Not recieved coupon Code
I have completed my Databricks Learning Festival and yet haven't received coupon Code
- 535 Views
- 1 replies
- 0 kudos
- 0 kudos
@nagsky1 Please feel free to DM me with the email address associated with your Academy account so I can verify your participation
- 0 kudos
- 1357 Views
- 4 replies
- 0 kudos
How to store SQL query output columns as variables to be used as parameters for API data call in DAT
I have a sql query which provides me with the below output :Select FirstName,LastName,Title From Default.Name Tony Gonzalez Mr Tom Brady Mr Patricia Carroll MissI would like to store FirstName, LastName & title column output...
- 1357 Views
- 4 replies
- 0 kudos
- 0 kudos
Hi @LearnDB1234 ,Here is the approach - You can make your API call dynamic by first running your SQL query and storing the results in a DataFrame. Then, you can loop through each row in the DataFrame and extract the FirstName and LastName values, pas...
- 0 kudos
- 795 Views
- 1 replies
- 0 kudos
Scheduling Jobs with Multiple Git Repos on a Single Job Cluster
Hi,I'm trying to create a scheduled job that runs notebooks from three different repos. However, since a job can only be associated with one repo, I've had to create three separate jobs and a master job that triggers them sequentially.This setup work...
- 795 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @SOlivero ,Try configuring a shared all-purpose cluster and set each job to use this existing cluster rather than creating new job-specific clusters, ensuring the cluster stays warm and avoiding startup delays. Another option is to restructure you...
- 0 kudos
- 5908 Views
- 6 replies
- 4 kudos
Resolved! Powerbi databricks connector should import column description
I posted this idea in ideas.powerbi.com as well, but it is quite unclear to me whether the powerbi databricks connector is in fact made by MS or Databricks, so I post it here as well!It is possible to add comments/descriptions to databricks database ...
- 5908 Views
- 6 replies
- 4 kudos
- 4 kudos
You can use this C# script in Tabular Editor to achieve this. Basically, all the comments can be accessed via the 'information_schema' in Databricks. Import the relevant columns from the schema using this query select * from samples.information_schem...
- 4 kudos
| User | Count |
|---|---|
| 1619 | |
| 790 | |
| 488 | |
| 349 | |
| 287 |
