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

SankaraiahNaray
by New Contributor II
  • 4266 Views
  • 4 replies
  • 0 kudos

OPTIMIZE with liquid clustering makes filter slower than without OPTIMIZE

I created 15 Million records as a Delta Table and i'm running a simple filter query on that table based on one column value - which will return only one record. Because all the values on that column are unique.Delta Table is not partitioned.Before en...

  • 4266 Views
  • 4 replies
  • 0 kudos
Latest Reply
-werners-
Esteemed Contributor III
  • 0 kudos

it seems that for this specific query Liquid Clustering has worse performance.  It does not have better performance for all queries.The following are examples of scenarios that benefit from clustering:Tables often filtered by high cardinality columns...

  • 0 kudos
3 More Replies
mvmiller
by New Contributor III
  • 7116 Views
  • 2 replies
  • 3 kudos

Module not found, despite it being installed on job cluster?

We observed the following error in a notebook which was running from a Databricks workflow: ModuleNotFoundError: No module named '<python package>'The error message speaks for itself - it obviously couldn't find the python package.  What is peculiar ...

  • 7116 Views
  • 2 replies
  • 3 kudos
Latest Reply
mvmiller
New Contributor III
  • 3 kudos

Thanks, @Walter_C.  Supposing that your second possible explanation, Cluster Initialization Timing, could be a factor, are there any best practices or recommendations for preventing this from being a recurring issue, down the road?

  • 3 kudos
1 More Replies
Etyr
by Contributor II
  • 4972 Views
  • 2 replies
  • 1 kudos

[FinOps] Tagging queries in databricks

Hello,I see that it is possible to tag catalogs/databases/tables. But I did not find a way to tag a query for our finop use case.In Azure you can check billings dependings on tags.A concrete example: In Azure Machine Learning, I have a schedule that ...

  • 4972 Views
  • 2 replies
  • 1 kudos
Latest Reply
Etyr
Contributor II
  • 1 kudos

@yoav Hello, sorry I am not interrested in a payed solution.

  • 1 kudos
1 More Replies
Avi759787
by New Contributor
  • 3390 Views
  • 0 replies
  • 0 kudos

Driver is up but is not responsive, likely due to GC.

I am using Interactive cluster to run frequent (every 15min) batch job.After certain time (example: 6hours), the cluster continuously starts showing Driver is up but is not responsive, likely due to GC. in event log and all jobs starts failing.If the...

  • 3390 Views
  • 0 replies
  • 0 kudos
WearBeard
by New Contributor
  • 4897 Views
  • 1 replies
  • 0 kudos

Consume updated data from the Materialized view and send it as append to a streaming table

Hello everyone! I'm using DLT and I'm pretty new to them. I'm trying to take the updates from a materialized view and send them to a streaming table as an append.For example, if I have a MV of 400 records, I want an append to be made to the streaming...

  • 4897 Views
  • 1 replies
  • 0 kudos
Latest Reply
Priyanka_Biswas
Databricks Employee
  • 0 kudos

Hi @WearBeard By default, streaming tables require append-only sources. The encountered error is due to an update or delete operation on the 'streaming_table_test'. To fix this issue, perform a Full Refresh on the 'streaming_table_test' table. You ca...

  • 0 kudos
Sas
by New Contributor II
  • 2266 Views
  • 0 replies
  • 0 kudos

Not able to create mount point in Databricks

HiI am trying to create mount point in Azure Databricks, but mount point creation is failing with below error messageDBUtils.FS Handler.mount() got an unexpected keyword argument 'extra_config'I am using following codedef setup_mount(storage_account_...

  • 2266 Views
  • 0 replies
  • 0 kudos
badari_narayan
by Databricks Partner
  • 2093 Views
  • 1 replies
  • 0 kudos

Exam got suspended without any reason

Hi Team,My Databricks Certified Associate Developer for Apache Spark 3.0 - Python exam got suspended on 7th March 2024I was there continuously in front of the camera and suddenly the alert appeared, and support person asked me to show the full table ...

  • 2093 Views
  • 1 replies
  • 0 kudos
Latest Reply
vinay076
New Contributor III
  • 0 kudos

hi @badari_narayan did you exam got rescheduled..i am also facing same issue my exam got suspemded 

  • 0 kudos
felix_counter
by New Contributor III
  • 3932 Views
  • 2 replies
  • 0 kudos

Fail to install package dependency located on private pypi server during .whl installation

Hello,I recently switched from DBR 12.2 LTS to DBR 13.3 LTS and observed the following behavior:My goal is to install a python library from a .whl file. I am using the UI for this task (Cluster settings -> Libraries -> Install new -> 'Python Whl' as ...

  • 3932 Views
  • 2 replies
  • 0 kudos
Latest Reply
robbe
Databricks Partner
  • 0 kudos

Hey Felix, I have run into a similar issue recently (my wheel needs a Git HTTPS redirect that's specified in the init script - but I can install it fine from inside a notebook).I wonder whether you found a solution (perhaps moving a more recent DBR v...

  • 0 kudos
1 More Replies
mvmiller
by New Contributor III
  • 4087 Views
  • 1 replies
  • 0 kudos

How to ignore Writestream UnknownFieldException error

I have a parquet file that I am trying to write to a delta table:df.writeStream  .format("delta")  .option("checkpointLocation", f"{targetPath}/delta/{tableName}/__checkpoints")  .trigger(once=True)  .foreachBatch(processTable)  .outputMode("append")...

  • 4087 Views
  • 1 replies
  • 0 kudos
Latest Reply
shan_chandra
Databricks Employee
  • 0 kudos

@mvmiller - Per the below documentation, The stream will fail with unknownFieldException, the schema evolution mode by default is addNewColumns. so, Databricks recommends configuring Auto Loader streams with workflows to restart automatically after s...

  • 0 kudos
AxelBrsn
by Databricks Partner
  • 9100 Views
  • 2 replies
  • 0 kudos

Resolved! Importing python to DLT - Not working with DLT Pipeline

Hello, we are trying to adapt our developments (notebook with delta tables), into Delta Live Tables Pipelines.We tried to import Python files that are very useful for data transformations (silver data cleaning, for example) :From the Cluster (run man...

Data Engineering
Delta Live Table
import
pipeline
python
  • 9100 Views
  • 2 replies
  • 0 kudos
Latest Reply
AxelBrsn
Databricks Partner
  • 0 kudos

The solution is to import from Python but also add the python file in the Pipeline settings, in the list of source code.

  • 0 kudos
1 More Replies
data-engineer-d
by Contributor
  • 5302 Views
  • 3 replies
  • 4 kudos

Parametrize the DLT pipeline for dynamic loading of many tables

I am trying to ingest hundreds of tables with CDC, where I want to create a generic/dynamic pipeline which can accept parameters (e.g table_name, schema, file path) and run the logic on it. However, I am not able to find a way to pass parameters to p...

Data Engineering
Delta Live Tables
  • 5302 Views
  • 3 replies
  • 4 kudos
Latest Reply
Gilg
Contributor II
  • 4 kudos

If you have different folders for each of your source tables, you can leverage python loops to naturally iterate over the folders.To do this, you need to create a create_pipeline function that has table_name, schema, path as your parameters. Inside t...

  • 4 kudos
2 More Replies
Ravikumashi
by Contributor
  • 2366 Views
  • 0 replies
  • 0 kudos

Issue with applying ACL's in Unit catlog enabled workspace

We have been using Hive Metastore in Databricks workspaces and recently enabled Unity Catalog for one of the workspace. However, we are encountering issues while applying grants on databases. The system is complaining, stating that table access contr...

Data Engineering
Databricks
spark simba
Unity Catalog
  • 2366 Views
  • 0 replies
  • 0 kudos
Tam
by New Contributor III
  • 13393 Views
  • 1 replies
  • 2 kudos

Delta Table on AWS Glue Catalog

I have set up Databricks cluster to work with AWS Glue Catalog by enabling the spark.databricks.hive.metastore.glueCatalog.enabled to true. However, when I create a Delta table on Glue Catalog, the schema reflected in the AWS Glue Catalog is incorrec...

Tam_0-1700157256870.png Tam_1-1700157262740.png
  • 13393 Views
  • 1 replies
  • 2 kudos
Latest Reply
monometa
New Contributor II
  • 2 kudos

Hi, could you please refer to something or explain in more detail your point about querying Delta Lake files directly instead of through the AWS Glue catalog and why it was highlighted as a best practice?

  • 2 kudos
NDK_1
by New Contributor II
  • 2444 Views
  • 1 replies
  • 0 kudos

I would like to Create a schedule in Databricks that runs a job on 1st working day of every month

I would like to create a schedule in Databricks that runs a job on the first working day of every month (working days referring to Monday through Friday). I tried using Cron syntax but didn't have any luck. Is there any way we can schedule this in Da...

  • 2444 Views
  • 1 replies
  • 0 kudos
Latest Reply
shan_chandra
Databricks Employee
  • 0 kudos

@NDK_1 - Cron syntax won't allow the combination of day of month and day of week. you can try creating two different schedules  - one for the first day, second day of the month and then add custom logic to check if it is an working day and then trigg...

  • 0 kudos
Labels