- 17573 Views
- 3 replies
- 0 kudos
Reason: Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages. Driver stacktrace
We are using the databricks 3 node cluster with 32 GB memory. It is working fine but some times it automatically throwing the error: Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues.
- 17573 Views
- 3 replies
- 0 kudos
- 0 kudos
If your job fails follow this:According to https://docs.databricks.com/jobs.html#jar-job-tips: "Job output, such as log output emitted to stdout, is subject to a 20MB size limit. If the total output has a larger size, the run will be canceled and ma...
- 0 kudos
- 13840 Views
- 1 replies
- 0 kudos
Resolved! SQL variables in a notebook
Hi, In an SQL notebook, using this link: https://docs.databricks.com/spark/latest/spark-sql/language-manual/set.html I managed to figure out to set values and how to get the value. SET my_val=10; //saves the value 10 for key my_val SET my_val; //dis...
- 13840 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @Mike K.., you can do this with widgets and getArgument. Here's a small example of what that might look like: https://community.databricks.com/s/feed/0D53f00001HKHZfCAP
- 0 kudos
- 31287 Views
- 12 replies
- 0 kudos
Resolved! Is there a better method to join two dataframes and not have a duplicated column?
I would like to keep only one of the columns used to join the dataframes. Using select() after the join does not seem straight forward because the real data may have many columns or the column names may not be known. A simple example belowllist = [(...
- 31287 Views
- 12 replies
- 0 kudos
- 0 kudos
This is an expected behavior. DataFrame.join method is equivalent to SQL join like thisSELECT*FROM a JOIN b ON joinExprsIf you want to ignore duplicate columns just drop them or select columns of interest afterwards. If you want to disambiguate you c...
- 0 kudos
- 14311 Views
- 2 replies
- 0 kudos
How to loop over spark dataframe with scala ?
Hello ! I 'm rookie to spark scala, here is my problem : tk's in advance for your help my input dataframe looks like this : index bucket time ap station rssi 0 1 00:00 1 1 -84.0 1 1 00:00 1 3 -67.0 2 1 00:00 1 4 -82.0 3 1 00:00 1 2 -68.0 4 1 00:00...
- 14311 Views
- 2 replies
- 0 kudos
- 0 kudos
Looping is not always necessary, I always use this foreach method, something like the following: aps.collect().foreach(row => <do something>)
- 0 kudos
- 8017 Views
- 2 replies
- 0 kudos
Parquet partitionBy - date column to nested folders
Hi, when writing a DataFrame to parquet using partitionBy(<date column>), the resulting folder structure looks like this: root |----------------- day1 |----------------- day2 |----------------- day3 Is it possible to create a structure like to foll...
- 8017 Views
- 2 replies
- 0 kudos
- 0 kudos
Hey @1stcommander​ You'll have to create those columns yourself. If it's something you will have to do often you could always write a function. In any case, imho it's not that much work. Im not sure what your problem is with the partition pruning. It...
- 0 kudos
- 8889 Views
- 2 replies
- 1 kudos
When to persist and when to unpersist RDD in Spark
Lets say i have the following:<code>val dataset2 = dataset1.persist(StorageLevel.MEMORY_AND_DISK) val dataset3 = dataset2.map(.....)1) 1)If you do a transformation on the dataset2 then you have to persist it and pass it to dataset3 and unpersist ...
- 8889 Views
- 2 replies
- 1 kudos
- 1 kudos
It is well documented here : http://spark.apache.org/docs/latest/programming-guide.html#rdd-persistence
- 1 kudos
- 5570 Views
- 2 replies
- 1 kudos
Handle comma inside cell of CSV
We are using spark-csv_2.10 > version 1.5.0 and reading the csv file column which contains comma " , " as one of the character. The problem we are facing is like that it treats the rest of line after the comma as new column and data is not interpre...
- 5570 Views
- 2 replies
- 1 kudos
- 1 kudos
Take a look here for options, http://spark.apache.org/docs/latest/api/python/pyspark.sql.html?highlight=dataframereader#pyspark.sql.DataFrameReader.csv If a csv file has commas then the tradition is to quote the string that contains the comma, In ...
- 1 kudos
- 7526 Views
- 2 replies
- 0 kudos
How to pass column names in selectExpr through one or more string parameters in spark using scala?
I am using script for CDC Merge in spark streaming. I wish to pass column values in selectExpr through a parameter as column names for each table would change. When I pass the columns and struct field through a string variable, I am getting error as...
- 7526 Views
- 2 replies
- 0 kudos
- 0 kudos
Hi @Swapan Swapandeep Marwaha, Can you pass them as a Seq as in below code, keyCols = Seq("col1", "col2"), structCols = Seq("struct(offset,KAFKA_TS) as otherCols")
- 0 kudos
- 4718 Views
- 1 replies
- 0 kudos
Making HTTP post requests on Spark using foreachPartition
Need some help to understand the behaviour of the below in Spark (using Scala and Databricks) I have some dataframe (reading from S3 if that matters), and would send that data by making HTTP post requests in batches of 1000 (at most). So I reparti...
- 4718 Views
- 1 replies
- 0 kudos
- 0 kudos
Need some help to understand the behaviour of the below in Spark (using Scala and Databricks) I have some dataframe (reading from S3 if that matters), and would send that data by making HTTP post requests in batches of 1000 (at most). So I repa...
- 0 kudos
- 18007 Views
- 2 replies
- 0 kudos
Python spark.read.text Path does not exist
Dear all, I want to read files with python from a storage account. I followed this instruction https://docs.microsoft.com/en-us/azure/azure-databricks/store-secrets-azure-key-vault. This is my python code: dbutils.fs.mount(source = "wasbs://contain...
- 18007 Views
- 2 replies
- 0 kudos
- 0 kudos
@rba76​ Make sure helloworld.txt file exists in the container1 folderI'm able to view the text file using the same commands as follows:Mount Blob Storage:dbutils.fs.mount( source = "wasbs://sampledata@azure.blob.core.windows.net/Azure", mount_po...
- 0 kudos
- 11979 Views
- 6 replies
- 0 kudos
Cannot Convert Column to Bool Error - When Converting dataframe column which is in string to date type in python
Hi All, I am trying to convert a dataframe column which is in the format of string to date type format yyyy-MM-DD? I have written a sql query and stored it in dataframe. df3 = sqlContext.sql(sqlString2) df3.withColumn(df3['CalDay'],pd.to_datetime(df...
- 11979 Views
- 6 replies
- 0 kudos
- 0 kudos
Registered to post this so forgive the formatting nightmare This is a python databricks script function that allows you to convert from string to datetime or date and utilising coalescefrom pyspark.sql.functions import coalesce, to_date def to_dat...
- 0 kudos
- 12190 Views
- 1 replies
- 0 kudos
How can I add jars ("spark.jars") to pyspark notebook?
I want to add a few custom jars to the spark conf. Typically they would be submitted along with the spark-submit command but in Databricks notebook, the spark session is already initialized. So, I want to set the jars in "spark.jars" property in the...
- 12190 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @dbansal, Install the libraries/jars while initialising the cluster.Please go through the documentation on the same below,https://docs.databricks.com/libraries.html#upload-a-jar-python-egg-or-python-wheel
- 0 kudos
- 8246 Views
- 1 replies
- 0 kudos
List all files in a Blob Container
I am trying to find a way to list all files, and related file sizes, in all folders and all sub folders. I guess these are called blobs, in the Databricks world. Anyway, I can easily list all files, and related file sizes, in one single folder, but ...
- 8246 Views
- 1 replies
- 0 kudos
- 0 kudos
from azure.storage.blob import BlockBlobService block_blob_service = BlockBlobService(account_name='your_acct_name', account_key='your_acct_key') mylist = [] generator = block_blob_service.list_blobs('rawdata') for blob in generator: mylist.append(...
- 0 kudos
- 48781 Views
- 11 replies
- 5 kudos
Resolved! How do I get the current cluster id?
I am adding Application Insights telemetry to my Databricks jobs and would like to include the cluster ID of the job run. How can I access the cluster id at run time? The requirement is that my job can programmatically retrieve the cluster id to in...
- 48781 Views
- 11 replies
- 5 kudos
- 5591 Views
- 1 replies
- 0 kudos
Sort within a groupBy with dataframe
Using Spark DataFrame, eg. myDf .filter(col("timestamp").gt(15000)) .groupBy("groupingKey") .agg(collect_list("aDoubleValue")) I want the collect_list to return the result, but ordered according to "timestamp". i.a. I want the GroupBy results...
- 5591 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @Laurent Thiebaud,Please use the below format to sort within a groupby, import org.apache.spark.sql.functions._ df.groupBy("columnA").agg(sort_array(collect_list("columnB")))
- 0 kudos