cancel
Showing results for 
Search instead for 
Did you mean: 
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
cancel
Showing results for 
Search instead for 
Did you mean: 

Forum Posts

dpc
by Contributor III
  • 3807 Views
  • 3 replies
  • 4 kudos

Resolved! Approach to monthly data snapshots

HelloI'm building a datawarehouse with all the usual facts and dimensionsIt will flush (truncate) and rebuild on a monthly basisUsers have the need to not only view the data now but also view it historically i.e. what it was a point in timeMy initial...

  • 3807 Views
  • 3 replies
  • 4 kudos
Latest Reply
dpc
Contributor III
  • 4 kudos

Great, thanks

  • 4 kudos
2 More Replies
angel531
by New Contributor II
  • 2171 Views
  • 3 replies
  • 3 kudos

Resolved! getting error while accessing dbfs from databricks community account and couldnt upload any files

Hi, I have enabled dbfs in my databricks community account and started the cluster. while accessing dbfs its throwing an error.

doubt.png
  • 2171 Views
  • 3 replies
  • 3 kudos
Latest Reply
satyakiguha
Databricks Partner
  • 3 kudos

Hi @Retired_mod I am no longer facing this issue, Thanks to the team for fixing it !  

  • 3 kudos
2 More Replies
fdeba
by New Contributor
  • 2214 Views
  • 2 replies
  • 0 kudos

DatabricksSession and SparkConf

Hi,I want to initialize a Spark session using `DatabricksSession`. However, it seems not possible to call `.config()` and pass it a `SparkConf` instance. The following works:# Initialize the configuration for the Spark session confSettings = [ ("...

  • 2214 Views
  • 2 replies
  • 0 kudos
Latest Reply
Witold
Databricks Partner
  • 0 kudos

In almost all cases you don't need to create a new spark session, as Databricks will do it for you automatically.If it's only about spark configurations, there are multiple ways to set it:Cluster settingsspark.conf.set

  • 0 kudos
1 More Replies
mkd
by New Contributor II
  • 6798 Views
  • 3 replies
  • 3 kudos

Resolved! CSV import error

Upload ErrorError occurred when processing file tips1.csv: [object Object].  I've been trying to import a csv file from my local machine to the databricks. The above mentioned error couldn't be resolved. Anyone pls help me in this regard.

  • 6798 Views
  • 3 replies
  • 3 kudos
Latest Reply
clentin
Contributor
  • 3 kudos

@Retired_mod - this is now fixed. Thank you so much for your prompt action. Appreciate it. 

  • 3 kudos
2 More Replies
kwinsor5
by New Contributor II
  • 3727 Views
  • 2 replies
  • 0 kudos

Delta Live Table autoloader's inferColumnTypes does not work

I am experimenting with DLTs/Autoloader. I have a simple, flat JSON file that I am attempting to load into a DLT (following this guide) like so:  CREATE OR REFRESH STREAMING LIVE TABLE statistics_live COMMENT "The raw statistics data" TBLPROPERTIES (...

  • 3727 Views
  • 2 replies
  • 0 kudos
Latest Reply
pavlos_skev
New Contributor III
  • 0 kudos

I had the same issue with a similar JSON structure as yours. Adding the option "multiLine" set to true fixed it for me.df = (spark.readStream.format("cloudFiles") .option("multiLine", "true") .option("cloudFiles.schemaLocation", schemaLocation) ...

  • 0 kudos
1 More Replies
kapilb
by New Contributor III
  • 4102 Views
  • 5 replies
  • 2 kudos

Resolved! Regarding problem in accessing table and uploading files

Hello team,I am new to databricks. I am using databricks community edition. Few days back I was able to access my tables and create tables by uploading csv files. But now I am getting error as "File Browsing Error" .It says Workspace is not set in Cu...

  • 4102 Views
  • 5 replies
  • 2 kudos
Latest Reply
kapilb
New Contributor III
  • 2 kudos

The issue has been resolved

  • 2 kudos
4 More Replies
Prajwal_082
by New Contributor II
  • 1175 Views
  • 0 replies
  • 0 kudos

DLT apply_changes_from_snapshot

Is there way to get auto incremented value for next version parameter like next version = previous version + 1 in that case how to get the previous version value.Below code is from documentation "Historical snapshot processing". The APPLY CHANGES API...

Prajwal_082_0-1721887681729.png
  • 1175 Views
  • 0 replies
  • 0 kudos
aalanis
by New Contributor II
  • 1999 Views
  • 3 replies
  • 2 kudos

Issues reading json files with databricks vs oss pyspark

Hi Everyone, I'm currently developing an application in which I read json files with nested structure. I developed my code locally on my laptop using the opensource version of pyspark (3.5.1) using a similar code to this:sample_schema:schema = Struct...

  • 1999 Views
  • 3 replies
  • 2 kudos
Latest Reply
sushmithajk
New Contributor II
  • 2 kudos

Hi, I'd like to try the scenario and find a solution. Would you mind sharing a sample file? 

  • 2 kudos
2 More Replies
Splush
by New Contributor II
  • 3514 Views
  • 1 replies
  • 1 kudos

Resolved! Row Level Security while streaming data with Materialized views

Hey,I have the following problem when trying to add row level security to some of our Materialized views. According to the documentation this feature is still in preview - nevertheless, I try to understand why this doesnt work and how it would be sup...

  • 3514 Views
  • 1 replies
  • 1 kudos
Latest Reply
raphaelblg
Databricks Employee
  • 1 kudos

Hello @Splush, There are 2 ways to create materialized views at the current moment:1. Through Databricks SQL: Use Materialized Views in Databricks SQL. These are the limitations. 2. Through DLT: Materialized View (DLT). All DLT tables are subject to ...

  • 1 kudos
robertkoss
by New Contributor III
  • 4732 Views
  • 7 replies
  • 1 kudos

Autoloader Schema Hint are not taken into consideration in schema file

I am using Autoloader with Schema Inference to automatically load some data into S3.I have one column that is a Map which is overwhelming Autoloader (it tries to infer it as struct -> creating a struct with all keys as properties), so I just use a sc...

  • 4732 Views
  • 7 replies
  • 1 kudos
Latest Reply
Witold
Databricks Partner
  • 1 kudos

Sorry, I didn't mean that your solution is poorly designed. I was only referring to the one of the main definitions of your bronze layer: You want to have a defined and optimized data layout, which is  source-driven at the same time. In other words: ...

  • 1 kudos
6 More Replies
phanindra
by New Contributor III
  • 7856 Views
  • 3 replies
  • 5 kudos

Resolved! Support for Varchar data type

In the official documentation for supported data types, Varchar is not listed. But in the product, we are allowed to create a field of varchar data type. We are building an integration with Databricks and we are confused if we should support operatio...

  • 7856 Views
  • 3 replies
  • 5 kudos
Latest Reply
szymon_dybczak
Esteemed Contributor III
  • 5 kudos

Hi @phanindra ,To be precise, Delta Lake format is based on parquet files. For strings, Parquet only has one data type: StringTypeSo, basically varchar(n) data type under the hood is represented as string with check constraint on the length of the st...

  • 5 kudos
2 More Replies
MichTalebzadeh
by Valued Contributor
  • 903 Views
  • 0 replies
  • 1 kudos

Navigating the Future: Key Questions for Implementing Production-Quality GenAI

"The Big Book of Generative AI from Databricks"https://lnkd.in/dR4VuEyQprovides a comprehensive guide to understanding and implementing Generative AI (GenAI) effectively within an enterprise. Here are some critical questions that businesses should co...

Data Engineering
FinCrime
GenAI ArtificialIntelligence DataScience AI MachineLearning Innovation Technology EnterpriseAI
  • 903 Views
  • 0 replies
  • 1 kudos
sanjay
by Valued Contributor II
  • 18221 Views
  • 13 replies
  • 10 kudos

Spark tasks too slow and not doing parellel processing

Hi,I have spark job which is processing large data set, its taking too long to process the data. In Spark UI, I can see its running 1 tasks out of 9 tasks. Not sure how to run this in parellel. I have already mentioned auto scaling and providing upto...

  • 18221 Views
  • 13 replies
  • 10 kudos
Latest Reply
plondon
New Contributor II
  • 10 kudos

Will it be any different if using Spark but within Azure, i.e. faster? 

  • 10 kudos
12 More Replies
Yyyyy
by New Contributor III
  • 2685 Views
  • 3 replies
  • 2 kudos

showing only a limited number of lines from the CSV file

Expected no of lines is - 16400 Showing only 20 No of records Script spark.conf.set(     "REDACTED",     "REDACTED" ) # File location file_location = "REDACTED" # Read in the data to dataframe df df = spark.read.format("CSV").option("inferSchema",...

  • 2685 Views
  • 3 replies
  • 2 kudos
Latest Reply
Yyyyy
New Contributor III
  • 2 kudos

 hi, pls look help mespark.conf.set(    "REDACTED",    "REDACTED")# File locationfile_location = "REDACTED"# Read in the data to dataframe dfdf = spark.read.format("CSV").option("inferSchema", "true").option("header", "true").option("delimiter", ",")...

  • 2 kudos
2 More Replies
Labels