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

EndreM
by • New Contributor III
  • 4464 Views
  • 8 replies
  • 1 kudos

Replay a stream after converting to liquid cluster failes

I have problem replaying a stream.I need to replay it because conversion from liquid clusterto partition doesnt work. I see a lot of garbage collectionand memory maxes out immediatly. Then the driver restarts.TO debug the problem I try to force only ...

  • 4464 Views
  • 8 replies
  • 1 kudos
Latest Reply
EndreM
New Contributor III
  • 1 kudos

After increasing the compute to one with 500 GB memory, the job was able to transfer ca 300 GB of data, but it produced a large amount of files, 26000. While the old table with partition and no liquid cluster had 4000 files with a total of 1.2 TB of ...

  • 1 kudos
7 More Replies
anilsampson
by • New Contributor III
  • 1329 Views
  • 1 replies
  • 0 kudos

Resolved! databricks dashboard via workflow task.

Hello, i am trying to trigger a databricks dashboard via workflow task.1.when i deploy the job triggering the dashboard task via local "Deploy bundle" command deployment is successful.2. when i try to deploy to a different environment via CICD while ...

  • 1329 Views
  • 1 replies
  • 0 kudos
Latest Reply
anilsampson
New Contributor III
  • 0 kudos

i think i figured out the issue , it had to do with the version of cli, updated the CICD to use latest version of clicurl -fsSL https://raw.githubusercontent.com/databricks/setup-cli/main/install.sh

  • 0 kudos
arendon
by • New Contributor II
  • 2456 Views
  • 2 replies
  • 1 kudos

Resolved! Asset Bundles: How to mute job failure notifications until final retry?

I'm trying to configure a job to only send failure notifications on the final retry failure (not on intermediate retry failures). This feature is available in the Databricks UI as "Mute notifications until the last retry", but I can't get this to wor...

  • 2456 Views
  • 2 replies
  • 1 kudos
Latest Reply
arendon
New Contributor II
  • 1 kudos

Thank you for the response, @lingareddy_Alva!I'll take a look at the workarounds you shared. 

  • 1 kudos
1 More Replies
dataminion01
by • New Contributor II
  • 1196 Views
  • 1 replies
  • 0 kudos

create streaming table using variable file path

is it possible to use a variable for the file path based on dates?files are stores in folders in this format yyyy/mm CREATE OR REFRESH STREAMING TABLE test  AS SELECT * FROM STREAM read_files(    "/Volumes/.....",    format => "parquet"  );

  • 1196 Views
  • 1 replies
  • 0 kudos
Latest Reply
Rishabh-Pandey
Databricks MVP
  • 0 kudos

@dataminion01  Yes, it is possible to use a variable or dynamic file path based on dates in some data processing frameworks , but not directly in static SQL DDL statements like CREATE OR REFRESH STREAMING TABLE unless the environment you're working e...

  • 0 kudos
Akshay_Petkar
by • Valued Contributor
  • 3316 Views
  • 1 replies
  • 1 kudos

How to Convert MySQL SELECT INTO OUTFILE and LOAD DATA INFILE to Databricks SQL?

Hi Community,I have some existing MySQL code :SELECT * FROM [table_name]INTO OUTFILE 'file_path'FIELDS TERMINATED BY '\t'OPTIONALLY ENCLOSED BY '"'LINES TERMINATED BY '\n';LOAD DATA INFILE 'file_path' REPLACE INTO TABLE [database].[table_name]FIELDS ...

  • 3316 Views
  • 1 replies
  • 1 kudos
Latest Reply
krishnakhadka28
New Contributor II
  • 1 kudos

Databricks SQL does not directly support MySQL’s SELECT INTO OUTFILE or LOAD DATA INFILE syntax. However, equivalent functionality can be achieved using Databricks features like saving to and reading from external locations like dbfs, s3 etc. I have ...

  • 1 kudos
erigaud
by • Honored Contributor
  • 11846 Views
  • 3 replies
  • 2 kudos

Dynamically specify pivot column in SQL

Hello everyone !I am looking for a way to dynamically specify pivot columns in a SQL query, so it can be used in a view. However we don't want to hard code the values that need to become columns, and would rather extract it from another table.I've se...

  • 11846 Views
  • 3 replies
  • 2 kudos
Latest Reply
lprevost
Contributor III
  • 2 kudos

I agree - not clear how to do this?  I'm thinking of using the pandas api.

  • 2 kudos
2 More Replies
Gecofer
by • Contributor III
  • 2405 Views
  • 2 replies
  • 1 kudos

Resolved! Inconsistent query results between dbt ETL run and SQL editor in Databricks

Hi everyone,I’m running into a strange issue in one of my ETL pipelines using dbt on Databricks, and I’d appreciate any insights or ideas. I have a query that is part of my dbt model. When I run the ETL process, the results from this query are incorr...

  • 2405 Views
  • 2 replies
  • 1 kudos
Latest Reply
Gecofer
Contributor III
  • 1 kudos

Hi @Isi Thanks so much for your insight!It turned out to be a combination of the two things you mentioned:There was a data masking policy applied to one of the columns, and while I had permissions to view the unmasked data, the service principal runn...

  • 1 kudos
1 More Replies
Debashisrajib
by • New Contributor II
  • 1470 Views
  • 1 replies
  • 0 kudos

Resolved! 65 technical questions.

I recently gave Databricks Data Engineer professional exam and I got really lengthy 65 technical questions. These questions are different from statistical questions.65 lengthy technical questions for 120 minutes is too much and this number is not men...

  • 1470 Views
  • 1 replies
  • 0 kudos
Latest Reply
Advika
Community Manager
  • 0 kudos

Hello @Debashisrajib! I’m sorry to hear that.As outlined in the exam details on Webassessor, Databricks certification exams include 60 scored questions, along with additional unscored questions that appear like regular ones but do not affect your fin...

  • 0 kudos
Abhimanyu
by • Databricks Partner
  • 1770 Views
  • 2 replies
  • 0 kudos

Why does df.dropna(how="all") fail when there is a . in a column name?

I'm working in a Databricks notebook and using Spark to query a Delta table. Here's the code I ran: df = spark.sql("select * from catalog.schema.table") df = df.dropna(how="all") display(df)This works fine unless the DataFrame has a column name that ...

  • 1770 Views
  • 2 replies
  • 0 kudos
Latest Reply
MujtabaNoori
New Contributor III
  • 0 kudos

Hi @Abhimanyu ,Yeah Actually in spark, '.'(dot) in columns is used for StructType by which the nested object can be accessed.But definitely You can rename thE columns dynamically whichever has '.' in it.Attached few screenshots for your reference tha...

  • 0 kudos
1 More Replies
chsoni12
by • New Contributor II
  • 2130 Views
  • 1 replies
  • 0 kudos

Resolved! Limitation in Managed Volumes Recovery — UNDROP Should Be Supported

Hello Databricks Community,While reviewing the Databricks official documentation and performing a POC on managed volumes, I observed that volumes cannot be recovered using the UNDROP command if accidentally deleted — unlike managed tables.Technically...

Data Engineering
@databricks
  • 2130 Views
  • 1 replies
  • 0 kudos
Latest Reply
Vidhi_Khaitan
Databricks Employee
  • 0 kudos

Thank you for highlighting this issue!Databricks is already working on implementing this in the future.

  • 0 kudos
farazahmad372
by • New Contributor II
  • 3904 Views
  • 3 replies
  • 0 kudos

TypeError: 'JavaPackage' object is not callable

from pyspark.sql import *if __name__ == "__main__": spark = SparkSession.builder \ .appName("hello Spark") \ .master("local[2]") \ .getOrCreate() data_list = [("Ravi",28), ("David",45), ("Abd...

  • 3904 Views
  • 3 replies
  • 0 kudos
Latest Reply
nikhilj0421
Databricks Employee
  • 0 kudos

@farazahmad372 May I know the DBR version and type of cluster?Are you using serverless?  

  • 0 kudos
2 More Replies
adurand-accure
by • Databricks Partner
  • 5291 Views
  • 5 replies
  • 2 kudos

Serverless job error - spark.rpc.message.maxSize

Hello, I am facing this error when moving a Workflow to serverless modeERROR : SparkException: Job aborted due to stage failure: Serialized task 482:0 was 269355219 bytes, which exceeds max allowed: spark.rpc.message.maxSize (268435456 bytes). Consid...

  • 5291 Views
  • 5 replies
  • 2 kudos
Latest Reply
adurand-accure
Databricks Partner
  • 2 kudos

Hello PiotrMi,We found out that the problem was caused by a collect() and managed to fix it by changing some codeThanks for your quick repliesBest regards,Antoine 

  • 2 kudos
4 More Replies
SakthiGanesh
by • New Contributor II
  • 3306 Views
  • 1 replies
  • 0 kudos

Unable to run python script from Azure DevOps git repo in Databricks Workflow job

Hi, I'm getting an issue while running a python script from Azure DevOps git repo in Databricks Workflow job task. The error stating internal commit path issue. But I referred the Source as Azure DevOps Services and I gave the branch name when settin...

  • 3306 Views
  • 1 replies
  • 0 kudos
Latest Reply
niteshm
Contributor
  • 0 kudos

@SakthiGanesh This is a known type of issue when running Databricks Workflows with Azure DevOps Git-backed repos.Did you try, Workspace Path Instead of Internal Git Path?If possible, use a .ipynb notebook-based task rather than a raw .py script, note...

  • 0 kudos
AgusBudianto
by • Contributor
  • 3794 Views
  • 8 replies
  • 1 kudos

Resolved! Is it possible for Store Procedure to be in Unity Catalog Dataricks

I got information that the latest release of Unity Catalog already supports Store Procedure, but I have searched from several sources that Unity catalog does not support Store Procedure, according to the following post: https://community.databricks.c...

  • 3794 Views
  • 8 replies
  • 1 kudos
Latest Reply
Louis_Frolio
Databricks Employee
  • 1 kudos

Yes, you can attend virtually and it is free. What I don't know is what is free. I believe the keynotes are free and some sessions.  You should definitely register and check it out.

  • 1 kudos
7 More Replies
CJOkpala
by • New Contributor II
  • 2447 Views
  • 4 replies
  • 1 kudos

Databricks DLT execution issue

I am having an issue when trying to do a full refresh of a DLT pipeline. I am getting the following error below: com.databricks.sql.managedcatalog.UnityCatalogServiceException: [RequestId=97d4fe52-b185-4757-b0b1-113cb96ae0bb ErrorClass=TABLE_ALREADY_...

CJOkpala_0-1748441402775.png CJOkpala_0-1748426421678.png
  • 2447 Views
  • 4 replies
  • 1 kudos
Latest Reply
nikhilj0421
Databricks Employee
  • 1 kudos

Are you facing the same issue, If you give a different name in the dlt decorator for the table? 

  • 1 kudos
3 More Replies
Labels