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

Raviiit
by • New Contributor II
  • 8009 Views
  • 4 replies
  • 8 kudos

Resolved! spark managed tables

Hi, I recently started learning about spark.  I was studying about spark managed tables. so as per docs " spark manages the both the data and metadata". Assume that i have a csv file in s3 and I read it into data frame like below.df = spark.read .for...

  • 8009 Views
  • 4 replies
  • 8 kudos
Latest Reply
Tharun-Kumar
Databricks Employee
  • 8 kudos

Yes, @Raviiit DBFS (Databricks File System) is a distributed file system used by Databricks clusters. DBFS is an abstraction layer over cloud storage (e.g. S3 or Azure Blob Store), allowing external storage buckets to be mounted as paths in the DBFS ...

  • 8 kudos
3 More Replies
databicky
by • Contributor II
  • 9900 Views
  • 5 replies
  • 0 kudos

File copy in adls

i am using dbutils.fs.copy(abfss://container/provsn/filen[ame.txt,abfss://container/data/sasam.txt)while.trying this copy method to copy the files it is showing urisyntax exception near the square bracket how can i read and  copy it

  • 9900 Views
  • 5 replies
  • 0 kudos
Latest Reply
dplante
Contributor II
  • 0 kudos

From looking at stack trace, it looks like URIException.  Easiest solution would be renaming the file so that there are no square brackets in the filename.  If this is not an option, it might help to URLEncode the path - https://stackoverflow.com/que...

  • 0 kudos
4 More Replies
brickster
by • New Contributor II
  • 7341 Views
  • 3 replies
  • 2 kudos

Passing values between notebook tasks in Workflow Jobs

I have created a Databricks workflow job with notebooks as individual tasks sequentially linked. I assign a value to a variable in one notebook task (ex: batchid = int(time.time()). Now, I want to pass this batchid variable to next notebook task.What...

  • 7341 Views
  • 3 replies
  • 2 kudos
Latest Reply
fijoy
Contributor
  • 2 kudos

@brickster You would use dbutils.jobs.taskValues.set() and dbutils.jobs.taskValues.get().See docs for more details: https://docs.databricks.com/workflows/jobs/share-task-context.html

  • 2 kudos
2 More Replies
Enzo_Bahrami
by • New Contributor III
  • 12386 Views
  • 6 replies
  • 1 kudos

Resolved! On-Premise SQL Server Ingestion to Databricks Bronze Layer

Hello everyone!So I want to ingest tables with schemas from the on-premise SQL server to Databricks Bronze layer with Delta Live Table and I want to do it using Azure Data Factory and I want the load to be a Snapshot batch load, not an incremental lo...

  • 12386 Views
  • 6 replies
  • 1 kudos
Latest Reply
Anonymous
Not applicable
  • 1 kudos

Hi @Parsa Bahraminejad​ Thank you for posting your question in our community! We are happy to assist you.To help us provide you with the most accurate information, could you please take a moment to review the responses and select the one that best an...

  • 1 kudos
5 More Replies
Chaitanya_Raju
by • Honored Contributor
  • 4472 Views
  • 2 replies
  • 0 kudos

Creating new group

Can someone help me by providing steps for creating a new group, as I could not able to find it anywhere? Actually, I wanted to create a new group for Hyderabad, India which I could not able to find in the Groups sections.@Kaniz Fatma​ @Sujitha Ramam...

  • 4472 Views
  • 2 replies
  • 0 kudos
Latest Reply
jose_gonzalez
Databricks Employee
  • 0 kudos

adding @Vidula Khanna​ for visibility. Is this possible to do?

  • 0 kudos
1 More Replies
chorongs
by • New Contributor III
  • 8901 Views
  • 4 replies
  • 3 kudos

Resolved! I have a question about the VACUUM feature!

History is piled up as aboveFor testing, I want to erase the history of the table with the VACUUM command."set spark.databricks.delta.retentionDurationCheck.After the option "enabled = False" was given, the command "VACUUM del_park retain 0 hours;" w...

chorongs_0-1688456804185.png
  • 8901 Views
  • 4 replies
  • 3 kudos
Latest Reply
Vinay_M_R
Databricks Employee
  • 3 kudos

Executing VACUUM performs garbage cleanup on the table directory. By default, a retention threshold of 7 days will be enforced. Please follow the below steps to perform VACCUM: 1.) SET spark.databricks.delta.retentionDurationCheck.enabled false; This...

  • 3 kudos
3 More Replies
kll
by • New Contributor III
  • 1597 Views
  • 0 replies
  • 0 kudos

SparkException: Job aborted due to stage failure when attempting to run grid_pointascellid

I am attempting to apply Mosaic's `grid_pointascellid` method on a spark dataframe with `lat`, `lon` columns.```import pyspark.sql.functions as F# Create a Spark DataFrame with a lat and lon columndf = spark.createDataFrame([("point1", 10.0, 20.0),("...

  • 1597 Views
  • 0 replies
  • 0 kudos
kll
by • New Contributor III
  • 1388 Views
  • 0 replies
  • 0 kudos

Mosaic's grid_boundary method returns inconsistent geometries

I am applying mosaic's `grid_boundary` method on a spark DataFrame containing a set of `h3_hex_ids`. The geometries returned are not consistent. i.e they could be either `lat, long` or `long, lat`.Here's a sample data```import pyspark.sql.functions a...

Data Engineering
geospatial
mosaic
  • 1388 Views
  • 0 replies
  • 0 kudos
442027
by • New Contributor II
  • 10114 Views
  • 2 replies
  • 3 kudos

Resolved! Delta Log checkpoints not being created?

It is mentioned in the delta protocol that checkpoints for delta tables are created every 10 commits - however when I modify a table after >10 separate operations (producing >10 separate json files in the _delta_log directory), no checkpoint files ar...

  • 10114 Views
  • 2 replies
  • 3 kudos
Latest Reply
Vinay_M_R
Databricks Employee
  • 3 kudos

 As the latest update now checkpointing of delta tables are created for every 100 commits. This is done for some improvement purpose.If you want to have a checkpoint file for delta table for every 10 commits or after any desired commits. You can cust...

  • 3 kudos
1 More Replies
Vsleg
by • Contributor
  • 9153 Views
  • 5 replies
  • 3 kudos

Resolved! Issue with Apache Sparkâ„¢ Programming with Databricks course

Hello,I found an issue with the Apache Sparkâ„¢ Programming with Databricks courses on Databricks Academy when trying to do the labs. The mount that the courses use for training data is failing with what looks to me like an authentication issue (see sc...

image
  • 9153 Views
  • 5 replies
  • 3 kudos
Latest Reply
Vsleg
Contributor
  • 3 kudos

I found the course Git Repo at (https://github.com/databricks-academy/apache-spark-programming-with-databricks-english), this works so using that instead of the 'apache-spark-programming-with-databricks.dbc' file available in the learning portal. #DA...

  • 3 kudos
4 More Replies
alexiswl
by • Contributor
  • 1560 Views
  • 0 replies
  • 0 kudos

R Notebooks start before all libraries have been installed

Has anyone else come across an issue where their R notebook executes cells before all libraries in the cluster have been installed?These are libraries in the cluster configuration since the start (not ones I've just put in). Please see attached my tw...

alexiswl_0-1688599641817.png alexiswl_1-1688599678822.png
Data Engineering
Libraries
Notebook
R
  • 1560 Views
  • 0 replies
  • 0 kudos
Hoviedo
by • New Contributor III
  • 1715 Views
  • 0 replies
  • 0 kudos

load data from sql server : python works well but spark does not

Hi, i have a problem with my on-premise sql conection from databricks.i have my python code wich use pymssql and it is working well but my spark code doest not and i am using the same credential for both, my spark code is """# Read data from SQL Serv...

  • 1715 Views
  • 0 replies
  • 0 kudos
Labels