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

thekushalvishwa
by • New Contributor
  • 46 Views
  • 1 replies
  • 0 kudos

Is Databricks Losing Its Charm in the Age of AI?

I've been working with Databricks for nearly eight years, and lately I've been reflecting on how our role as data engineers is evolving.One thing I've noticed is that development is increasingly becoming about prompting AI, troubleshooting issues, fi...

  • 46 Views
  • 1 replies
  • 0 kudos
Latest Reply
data_pulse
Contributor
  • 0 kudos

@thekushalvishwa AI can write the pipeline in few seconds. It might not explain the DBU bill to finance. A timely post, and one I suspect many of us relate to.My take is that AI has made writing the code cheap, so our value has moved to the parts it ...

  • 0 kudos
2nonto
by • Visitor
  • 74 Views
  • 0 replies
  • 0 kudos

Pushing a notebook with outputs to Github

I am experiencing an error when trying to commit output and Databricks notebook to GitHub. The error message states, "Error creating or updating commit outputs config file."Could you please assist me in resolving this issue?

Screenshot 2026-11-11 214121.png
  • 74 Views
  • 0 replies
  • 0 kudos
AlexMorgan
by • New Contributor
  • 203 Views
  • 3 replies
  • 1 kudos

How do you test data quality in a Delta Lake pipeline?

I'm exploring practical approaches to validating data quality in Databricks pipelines.For pipelines that ingest data into Delta tables, what checks do you typically automate at each stage?I'm particularly interested in handling:Schema changes and sch...

  • 203 Views
  • 3 replies
  • 1 kudos
Latest Reply
balajij8
Esteemed Contributor III
  • 1 kudos

The right pattern is to treat validation as multi layered instead of a single gate. You can start with handling schema changes and schema evolution at ingestion. You can configure Auto Loader with a dedicated schema at the ingestion point to prevent ...

  • 1 kudos
2 More Replies
ifishbein
by • New Contributor
  • 235 Views
  • 3 replies
  • 4 kudos

Resolved! SparkSession.getActiveSession() is Suddenly Broken in Python Multi-threading

Hello everyone,Around 3PM EST yesterday (2026-11-12), dozens of Lakeflow jobs started failing on both classic and serverless compute with distinct symptoms1. On classic compute (DBR 15.4), reading a file from S3 would result in a PATH NOT FOUND error...

  • 235 Views
  • 3 replies
  • 4 kudos
Latest Reply
Louis_Frolio
Databricks Employee
  • 4 kudos

Hello @ifishbein, I dug in and here is what I found. The serverless behavior is explainable, and your workaround is the right one. Serverless runs on Spark Connect, and in the Spark Connect flavor of PySpark SparkSession.getActiveSession() is backed ...

  • 4 kudos
2 More Replies
Jack17
by • New Contributor
  • 219 Views
  • 4 replies
  • 0 kudos

Lakebase Data API

We need to bring the json data from external API and need to load it into lakebase API tables.Please suggest in connecting this.

  • 219 Views
  • 4 replies
  • 0 kudos
Latest Reply
suranga
Databricks Partner
  • 0 kudos

Hi @Jack17,One small addition to the service principal advice above, because it makes testing a lot easier. Since 12 November, OAuth on-behalf-of for service principals is generally available, so you can test the Data API locally as the same service ...

  • 0 kudos
3 More Replies
MichaelAnckaert
by • New Contributor
  • 130 Views
  • 1 replies
  • 0 kudos

Issue with CDC ingestion pipeline

Hello everyoneI'm trying to setup an ingestion pipeline from a mysql server and keep running into an issue. The setup was validated and the pipeline created. When I run the pipeline the destination tables are created in the schema, but then the follo...

  • 130 Views
  • 1 replies
  • 0 kudos
Latest Reply
suranga
Databricks Partner
  • 0 kudos

Hi @MichaelAnckaert,The interesting part is the path in the error: s3:/ with nothing after it. That isn't coming from MySQL. It looks like the pipeline tried to resolve a storage location in Unity Catalog and got back an empty S3 path, and since the ...

  • 0 kudos
Raj_DB
by • Contributor II
  • 1207 Views
  • 11 replies
  • 14 kudos

How to Connect Databricks to Snowflake & Query Live Data?

Hi everyone,I am looking for a method to connect Databricks to Snowflake so I can query and transform the data directly in a notebook. I specifically want to avoid methods that just perform a one-time copy of the tables into Databricks, as I need the...

  • 1207 Views
  • 11 replies
  • 14 kudos
Latest Reply
Louis_Frolio
Databricks Employee
  • 14 kudos

@raj , if you are happy with the answer and it addresses your issue please mark "Accept as Solution" so that others can have confidence in the response. Cheers, Lou.

  • 14 kudos
10 More Replies
rjmcbride
by • New Contributor
  • 245 Views
  • 4 replies
  • 2 kudos

Serverless declarative pipeline ingestion from ADLS is running x4 SLOWER randomly

 Hi all,A full refresh of one Auto Loader streaming table in a serverless #Lakeflow (Declarative) pipeline has become about 4x slower (all to do with a single streaming table), and I'd like help understanding why. Nothing on our side changed. The onl...

  • 245 Views
  • 4 replies
  • 2 kudos
Latest Reply
saurabh18cs
Honored Contributor III
  • 2 kudos

Hi @rjmcbride what if you fiddle around wit max worksers for your serverless here  

  • 2 kudos
3 More Replies
Pravieen
by • New Contributor
  • 141 Views
  • 2 replies
  • 0 kudos

Request for Guidance: Enabling PostgreSQL CDC in Azure Databricks Lakeflow Connect

Hello Databricks Community,I am using Azure Databricks Lakeflow Connect with a PostgreSQL source.The CDC option is disabled in the PostgreSQL ingestion wizard, and I see the following message:This mode is not available in this workspace for the selec...

  • 141 Views
  • 2 replies
  • 0 kudos
Latest Reply
saurabh18cs
Honored Contributor III
  • 0 kudos

Hi @Pravieen worth looking this page : https://www.databricks.com/blog/push-based-cdc-unity-catalog-zerobus-ingest-and-debeziumBr

  • 0 kudos
1 More Replies
dbernstein_tp
by • Contributor III
  • 1994 Views
  • 23 replies
  • 8 kudos

MS Fabric Direct Lake, works with delta tables only?

Lately we started using Direct Lake to use the results of our ingestion pipelines (gold tables) in PBI dashboards. This is working ok but has one annoying and troublesome issue. Which is: the gold tables are the end result of declarative pipelines so...

  • 1994 Views
  • 23 replies
  • 8 kudos
Latest Reply
suranga
Databricks Partner
  • 8 kudos

Hi @dbernstein_tp,Thanks for testing all of that and reporting back. Good to know deletion vectors didn't upset Direct Lake.I think your two findings are really the same problem. If most of the gold MVs are fully recomputed on every update, each refr...

  • 8 kudos
22 More Replies
faruk
by • Contributor II
  • 307 Views
  • 5 replies
  • 0 kudos

Lakeflow Connect (Oracle): backfill a single new column without a full refresh of the table

Hi everyone,We ingest Oracle tables into a Bronze layer with Lakeflow Connect, and our Silver layer is a Lakeflow Spark Declarative Pipeline made of materialized views that read the Bronze tables and apply types and comments from our data dictionary....

  • 307 Views
  • 5 replies
  • 0 kudos
Latest Reply
faruk
Contributor II
  • 0 kudos

@pradeep_singhThanks for the explanation, that makes sense. Let me give a bit more context on my case, because I think it's slightly different.The data has already been corrected in Oracle. The problem is that Lakeflow Connect resumes ingestion from ...

  • 0 kudos
4 More Replies
Visheshd_21
by • New Contributor
  • 412 Views
  • 4 replies
  • 0 kudos

Databricks Free Edition – AWS S3 Storage Credential Validation Fails at Assume Role

Hi Databricks Team,I'm trying to connect an AWS S3 bucket to Databricks Unity Catalog using an IAM role in Databricks Free Edition.EnvironmentDatabricks Edition: Free EditionCloud: AWSWorkspace region: us-east-2Metastore region: us-east-2S3 bucket re...

  • 412 Views
  • 4 replies
  • 0 kudos
Latest Reply
twarangupta
New Contributor
  • 0 kudos

Hi @Visheshd_21 I did some digging.Same error here on Free Edition: Assume Role fails, and the other two checks are skipped. I went through all the suggestions above. The validate messages show the correct role ARN, UC principal and external ID; both...

  • 0 kudos
3 More Replies
MikeGo
by • Valued Contributor
  • 271 Views
  • 4 replies
  • 2 kudos

Zerobus to lakebase

Hi,Is there a plan to make lakebase as destination of Zerobus?Thanks.

  • 271 Views
  • 4 replies
  • 2 kudos
Latest Reply
MikeGo
Valued Contributor
  • 2 kudos

Why assume 100 indexes on a Lakebase landing table while picturing a Delta table with at most 4 LC keys? Nobody will create 100 indexes for a landing table.Five seconds is far from a good num for some use cases. With Lakebase, data can be queried as ...

  • 2 kudos
3 More Replies
Brahmareddy
by • Esteemed Contributor II
  • 241 Views
  • 2 replies
  • 1 kudos

Making AI-agent writes safe on Databricks: lineage, shallow clones, null-safe diffs, rollback

A pipeline change can run successfully and still ship wrong data: a join that duplicates rows, a filter that moves a revenue total by a few percent. With AI agents now writing more pipeline code, I wanted a check that runs before a change reaches pro...

  • 241 Views
  • 2 replies
  • 1 kudos
Latest Reply
DoTA
Honored Contributor
  • 1 kudos

The full-table checksum catching the 1-row delete is a nice find, sampling hiding it is exactly what people don't expect. One thing I'd double check is the sum of xxhash64. The hash spreads across the whole BIGINT range, so adding up a couple million...

  • 1 kudos
1 More Replies
DB1To3
by • Valued Contributor II
  • 311 Views
  • 6 replies
  • 4 kudos

Resolved! Missing spark structured streaming metadata blobs?

I'm exploring spark structured streaming, and contemplating uses for it.I'd like to launch a job on a recurring basis from an external scheduler.  It will launch a spark job with trigger (availableNow=True). I'm concerned about overlapping executions...

DB1To3_0-1794341533309.png
  • 311 Views
  • 6 replies
  • 4 kudos
Latest Reply
saurabh18cs
Honored Contributor III
  • 4 kudos

Hi @DB1To3 Just make this concurrent run to 1 for your streaming jobs are your problem is sorted , it wont corrupt checkpoint locatiion  

  • 4 kudos
5 More Replies
Labels