- 4267 Views
- 3 replies
- 9 kudos
Resolved! Unable to create Databricks workspace using Terraform on AWS
HI Team,we are using below workspace config scripts, when we try to create workspace previously from EC2 Instance, we are able to create Workspace without any issue. but when we are trying to run through Github actions, we are getting below errorErro...
- 4267 Views
- 3 replies
- 9 kudos
- 9 kudos
@karthik p​ this can be fixed by setting timeout. Please check this https://kb.databricks.com/en_US/cloud/failed-credential-validation-checks-error-with-terraform
- 9 kudos
- 1799 Views
- 1 replies
- 1 kudos
display() not updating after 1000 rows
Hello folks! I am calling display() on a streaming query sourced from a delta table. The output from display() displays the new rows added to the source table. But as soon as the output results hit 1000 rows, the output is not updated anymore. As a r...
- 1799 Views
- 1 replies
- 1 kudos
- 1 kudos
aggregate function followed by timestamp field sorted in descending order did the trick:streaming_df.groupBy("field1", "time_field").max("field2").orderBy(col("time_field").desc()).display()
- 1 kudos
- 3018 Views
- 2 replies
- 1 kudos
How do you correctly access the spark context in DLT pipelines?
I have some code that uses RDDs, and the sc.parallelize() and rdd.toDF() methods to get a dataframe back out. The code works in a regular notebook (and if I run the notebook as a job) but fails if I do the same thing in a DLT pipeline. The error mess...
- 3018 Views
- 2 replies
- 1 kudos
- 1 kudos
Thanks for your help Alex, I ended up re-writing my code with spark UDFs -- maybe there is a better solution with only the Dataframe API but I couldn't find it. To summarize my problem: I was trying to un-nest a large json blob (the fake data in my f...
- 1 kudos
- 2236 Views
- 0 replies
- 0 kudos
A/B Testing:- Â A/B testing is the process of comparing two variations as well as two versions of same item and offer the best one in between both of t...
A/B Testing:- A/B testing is the process of comparing two variations as well as two versions of same item and offer the best one in between both of them. Well before doing A/B testing you need to be focus on one problem that you want to resolve and ...
- 2236 Views
- 0 replies
- 0 kudos
- 1622 Views
- 0 replies
- 2 kudos
Does databricks support writing the data in Iceberg format?
As I understand databricks supports conversion from Iceberg format to Delta using the command belowCONVERT TO DELTA iceberg.`abfss://container-name@storage-account-name.dfs.core.windows.net/path/to/table`; -- uses Iceberg manifest for metadataHowever...
- 1622 Views
- 0 replies
- 2 kudos
- 1553 Views
- 0 replies
- 0 kudos
databricks spark sql Custom table valued function + struct really slow (minutes for a single row)
I'm using azure databricksI have a custom table valued function which takes a URL as a parameter and outputs a single row table with certain elements from the URL extracted/labelled(i get search activity URLs and when in a specific format I can retri...
- 1553 Views
- 0 replies
- 0 kudos
- 23891 Views
- 3 replies
- 2 kudos
Resolved! Choosing the optimal cluster size/specs.
Hello everyone,I am trying to determine the appropriate cluster specifications/sizing for my workload:Run a PySpark task to transform a batch of input avro files to parquet files and create or re-create persistent views on these parquet files. This t...
- 23891 Views
- 3 replies
- 2 kudos
- 2 kudos
If the data is 100MB, then I'd try a single node cluster, which will be the smallest and least expensive. You'll have more than enough memory to store it all. You can automate this and use a jobs cluster.
- 2 kudos
- 4936 Views
- 4 replies
- 0 kudos
Failed to install cluster scoped SparkR library
Attempting to install SparkR to the cluster and successfully installed other packages such as tidyverse via CRAN. The error is copied below, any help you can provide is greatly appreciated!Databricks runtime 10.4 LTSLibrary installation attempted on ...
- 4936 Views
- 4 replies
- 0 kudos
- 0 kudos
Hi @Ross Hamilton​ ,I believe SparkR comes inbuilt with Databricks RStudio and you don't have to install it explicitly. You can directly import it with library(SparkR) and it works for you from your above comment.The error message you see could be re...
- 0 kudos
- 4621 Views
- 3 replies
- 0 kudos
Resolved! Multi-Hop Architecture for ingestion data via http API
I'd like to know what is the design pattern for ingesting data via http API request. The pattern needs use multi-hop architecture. Do we need ingest JSON output to cloud storage first (not bronze layer), then use auto loader to process data further? ...
- 4621 Views
- 3 replies
- 0 kudos
- 0 kudos
The API -> Cloud Storage -> Delta is more suitable approach.Auto Loader helps not to lose any data (it keeps track of discovered files in the checkpoint location using RocksDB to provide exactly-once ingestion guarantees), enables schema inference ev...
- 0 kudos
- 18004 Views
- 5 replies
- 2 kudos
Python Read csv - Don't consider comma when its within the quotes, even if the quotes are not immediate to the separator
I have data like, below and when reading as CSV, I don't want to consider comma when its within the quotes even if the quotes are not immediate to the separator (like record #2). 1 and 3 records are good if we use separator, but failing on 2nd record...
- 18004 Views
- 5 replies
- 2 kudos
- 2 kudos
Hi, I think you can use this option for the csvReadeespark.read.options(header = True, sep = ",", unescapedQuoteHandling = "BACK_TO_DELIMITER").csv("your_file.csv")especially the unescapedQuoteHandling. You can search for the other options at this l...
- 2 kudos
- 7344 Views
- 4 replies
- 1 kudos
Resolved! Spark Sql Connector :
i am trying to read data from azure sql database from databricks. azure sql database is created with private link endpoint.Using DBR 10.4 LTS Cluster and expectation is the connector is pre installed as per documentation.using the below code to fetch...
- 7344 Views
- 4 replies
- 1 kudos
- 1 kudos
It seems that .option("databaseName", "test") is redundant here as you need to include the db name in the url.Please verify that you use a connector compatible to your cluster's Spark version : Apache Spark connector: SQL Server & Azure SQL
- 1 kudos
- 2205 Views
- 1 replies
- 0 kudos
Does spark utilise a temporary stage when writing to snowflake? How does that work?
Folks , when I want to push data to snowflake I need to use a stage for files before copying data over. However, when I utilise the net.snowflake.spark.snowflake.Utils library and do a spark.write as in...spark.read.format("csv") .option("header", ...
- 2205 Views
- 1 replies
- 0 kudos
- 0 kudos
Yes it uses a temporary stage. should have just looked in snowflake history
- 0 kudos
- 1786 Views
- 0 replies
- 4 kudos
Databricks streaming job issue with Autoloader for new checkpoint.
Hi Team,I am trying to run a streaming job in databricks, used Autoloader approach for reading the files from the Azure Datalake Gen2 which is in parquet format. I have created a new checkpoint, so first offset is getting created but throwing an erro...
- 1786 Views
- 0 replies
- 4 kudos
- 3063 Views
- 3 replies
- 1 kudos
Resolved! Error message when editing schedule cron expression on job
When attempting to edit the schedule cron expression on one of our jobs we receive the following error message:Cluster validation error: Validation failed for spark_conf, spark.databricks.acl.dfAclsEnabled must be false (is "true") The spark.databric...
- 3063 Views
- 3 replies
- 1 kudos
- 1534 Views
- 0 replies
- 0 kudos
Help integrating streaming pipeline with AWS services S3 and Lambda
Hi there, I am trying to build a delta live tables pipeline that ingests gzip compressed archives as they're uploaded to S3. The archives contain 2 files in a proprietary format, and one is needed to determine how to parse the other. Once the file co...
- 1534 Views
- 0 replies
- 0 kudos
| User | Count |
|---|---|
| 1628 | |
| 790 | |
| 510 | |
| 349 | |
| 287 |
