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

jenitjain
by New Contributor
  • 1234 Views
  • 2 replies
  • 0 kudos

Certifications questions

What are the timings and days between which we can get certified? Can we purchase a certification at the location or are we supposed to purchase it beforehand?

  • 1234 Views
  • 2 replies
  • 0 kudos
Latest Reply
Cert-Team
Databricks Employee
  • 0 kudos

Online exams can be purchased and taken anytime. Is this question related to DAIS?

  • 0 kudos
1 More Replies
guangyi
by Contributor III
  • 1229 Views
  • 0 replies
  • 0 kudos

How to make a DLT pipeline trigger another pipeline?

For example, I have 2 DLT pipelines, one is used for computing user gender distribution, another is used for compute user location distribution. In the first pipeline, I follow the medallion architecture creating the bronze, silver, gold table one by...

  • 1229 Views
  • 0 replies
  • 0 kudos
swathiG
by New Contributor III
  • 7154 Views
  • 7 replies
  • 1 kudos

Databrick IP address

I'm trying to call api in databricks notebook .But while calling  api inside databricks notebook  it is giving error saying "403" forbidden. I think it seems issue with IP address can any one help me to know which IP of databricks need to be whitelis...

swathiG_0-1718859645301.png
  • 7154 Views
  • 7 replies
  • 1 kudos
Latest Reply
swathiG
New Contributor III
  • 1 kudos

@jacovangelder can you please let me know where can I get compute IP address

  • 1 kudos
6 More Replies
laudhon
by New Contributor II
  • 6149 Views
  • 6 replies
  • 3 kudos

Resolved! Why is My MIN MAX Query Still Slow on a 29TB Delta Table After Liquid Clustering and Optimization?

Hello,I have a large Delta table with a size of 29TB. I implemented Liquid Clustering on this table, but running a simple MIN MAX query on the set cluster column is still extremely slow. I have already optimized the table. Am I missing something in m...

  • 6149 Views
  • 6 replies
  • 3 kudos
Latest Reply
LuisRSanchez
New Contributor III
  • 3 kudos

Hithis operation should take seconds because it use the precomputed statistics for the table. Then few elements to verify:if the data type is datetime or integer should work, if it is string data type then it needs to read all data.verify the column ...

  • 3 kudos
5 More Replies
dat_77
by New Contributor
  • 6769 Views
  • 1 replies
  • 0 kudos

Change Default Parallelism ?

HII attempted to parallelize my Spark read process by setting the default parallelism using spark.conf.set("spark.default.parallelism", "X"). However, despite setting this configuration, when I checked sc.defaultParallelism in my notebook, it display...

  • 6769 Views
  • 1 replies
  • 0 kudos
Latest Reply
irfan_elahi
Databricks Employee
  • 0 kudos

sc.defaultParallelism is based on the number of worker cores in the cluster. It can't be overridden. The reason you are seeing 200 tasks is because of spark.sql.shuffle.partitions (whose default value is 200). This determines the number of shuffle pa...

  • 0 kudos
Awoke101
by New Contributor III
  • 8302 Views
  • 8 replies
  • 0 kudos

Resolved! Pandas_UDF not working on shared access mode but works on personal cluster

 The "dense_vector" column does not output on show(). Instead I get the error below. Any idea why it doesn't work on the shared access mode? Any alternatives? from fastembed import TextEmbedding, SparseTextEmbedding from pyspark.sql.pandas.functions ...

Data Engineering
pandas_udf
shared_access
udf
  • 8302 Views
  • 8 replies
  • 0 kudos
Latest Reply
jacovangelder
Databricks MVP
  • 0 kudos

For some reason a moderator is removing my pip freeze? no idea why. Maybe too long/spammy for a comment.Anyway, I am using DBR 14.3 LTS with Shared Access Mode. I haven't installed any other version apart from fastembed==0.3.1. Included a screenshot ...

  • 0 kudos
7 More Replies
DavidS1
by New Contributor
  • 1385 Views
  • 1 replies
  • 0 kudos

Cost comparison of DLT to custom pipeline

Hello, our company currently has a number of custom pipelines written in python for ETL, and I want to do an evaluation of DLT to see if that will make things more efficient.  A problem is that there is a restriction on using DLT "because it is too e...

  • 1385 Views
  • 1 replies
  • 0 kudos
Latest Reply
Zume
New Contributor II
  • 0 kudos

DLT is expensive in my opinion. I tried to run a simple notebook that just reads a parquet file into a dataframe and write it out to a cloud storage and I got an error that i hit my CPU instance limit for my azure subscription. I just gave up after t...

  • 0 kudos
ksenija
by Contributor
  • 6417 Views
  • 8 replies
  • 1 kudos

DLT pipeline error key not found: user

When I try to create a DLT pipeline from a foreign catalog (BigQuery), I get this error: java.util.NoSuchElementException: key not found: user.I used the same script to copy Salesforce data and that worked completely fine.

  • 6417 Views
  • 8 replies
  • 1 kudos
Latest Reply
ksenija
Contributor
  • 1 kudos

Hi @lucasrocha ,Any luck with this error? I guess it's something with connection to BigQuery, but I didn't find anything.Best regards,Ksenija

  • 1 kudos
7 More Replies
Chinu
by New Contributor III
  • 4579 Views
  • 3 replies
  • 2 kudos

How do I access to DLT advanced configuration from python notebook?

Hi Team, Im trying to get DLT Advanced Configuration value from the python dlt notebook. For example, I set "something": "some path" in Advanced configuration in DLT and I want to get the value from my dlt notebook. I tried "dbutils.widgets.get("some...

  • 4579 Views
  • 3 replies
  • 2 kudos
Latest Reply
Mo
Databricks Employee
  • 2 kudos

here you can find the documentation on how to use parameters in dlt (sql and python): https://docs.databricks.com/en/delta-live-tables/settings.html#parameterize-dataset-declarations-in-python-or-sql

  • 2 kudos
2 More Replies
vanagnostopoulo
by New Contributor III
  • 3307 Views
  • 5 replies
  • 0 kudos

validate bundle does not work on windows 10 PRO x64

I use the databricks clidatabricks_cli_0.221.1_windows_amd64-signedand when I rundatabricks bundle validatein my project I get"Error: no shell found" In git-bash it works but I have other problems there.

  • 3307 Views
  • 5 replies
  • 0 kudos
Latest Reply
jacovangelder
Databricks MVP
  • 0 kudos

That's strange. Just checking, are you running it from the right folder? (location of databricks.yml file)? 

  • 0 kudos
4 More Replies
WynanddB
by New Contributor III
  • 9151 Views
  • 4 replies
  • 3 kudos

Invalid characters in column name

I get the following error   com.databricks.sql.transaction.tahoe.DeltaAnalysisException: [DELTA_INVALID_CHARACTERS_IN_COLUMN_NAMES] Found invalid character(s) among ' ,;{}()\n\t=' in the column names of your schema.It's a new instance of databricks a...

  • 9151 Views
  • 4 replies
  • 3 kudos
Latest Reply
jacovangelder
Databricks MVP
  • 3 kudos

My guess is you have a new line character (\n) in one of the CSV header columns. You don't very easily spot them. Have you checked for that? You can also try .option("header","true") so Spark doesn't think of your header as content. Might also want t...

  • 3 kudos
3 More Replies
Nastia
by New Contributor III
  • 3591 Views
  • 7 replies
  • 2 kudos

Resolved! I keep getting dataset from spark.table command (instead of dataframe)

I am trying to create a simple dlt pipeline: @dlt.tabledef today_latest_execution():  return spark.sql("SELECT * FROM LIVE.last_execution") @on_event_hookdef write_events_to_x(event  if (     today_latest_execution().count() == 0      try:       ... ...

  • 3591 Views
  • 7 replies
  • 2 kudos
Latest Reply
-werners-
Esteemed Contributor III
  • 2 kudos

what if you do:return spark.sql("SELECT * FROM LIVE.last_execution").toDF()

  • 2 kudos
6 More Replies
RobinK
by Contributor
  • 17589 Views
  • 12 replies
  • 14 kudos

Resolved! Databricks Jobs do not run on job compute but on shared compute

Hello,since last night none of our ETL jobs in Databricks are running anymore, although we have not made any code changes.The identical jobs (deployed with Databricks asset bundles) run on an all-purpose cluster, but fail on a job cluster. We have no...

  • 17589 Views
  • 12 replies
  • 14 kudos
Latest Reply
jcap
New Contributor II
  • 14 kudos

I do not believe this is solved, similar to a comment over here:https://community.databricks.com/t5/data-engineering/databrickssession-broken-for-15-1/td-p/70585We are also seeing this error in 14.3 LTS from a simple example:from pyspark.sql.function...

  • 14 kudos
11 More Replies
Labels