- 19447 Views
- 5 replies
- 3 kudos
com.databricks.sql.io.FileReadException: Error while reading file dbfs:
I ran the below statement and got the error %python data = sqlContext.read.parquet("/FileStore/tables/ganesh.parquet") display(data) Error: SparkException: Job aborted due to stage failure: Task 0 in stage 27.0 failed 1 times, most recent failure:...
- 19447 Views
- 5 replies
- 3 kudos
- 3 kudos
I'm having a similar issue reading a JSON file. It is ~550MB compressed and is on a single line: val cfilename = "c_datafeed_20200128.json.gz" val events = spark.read.json(s"/mnt/c/input1/$cfilename") display(events) The filename is correct and t...
- 3 kudos
- 12721 Views
- 2 replies
- 1 kudos
FileNotFoundError: [Errno 2] No such file or directory or IsADirectoryError: [Errno 21] Is a directory
I have been trying to open a file on the dbfs using all different combinations: if I use the following code: with open("/dbfs/FileStore/df/Downloadedfile.csv", 'r', newline='') as f I get IsADirectoryError: [Errno 21] Is a directory with open("dbfs:...
- 12721 Views
- 2 replies
- 1 kudos
- 1 kudos
To get rid of this error you can try using Python file exists methods to check that at least python sees the file exists or not. In other words, you can make sure that the user has indeed typed a correct path for a real existing file. If the user do...
- 1 kudos
- 6690 Views
- 3 replies
- 1 kudos
Resolved! JavaPackage' object is not callable :: Mlean
Hi Folks, We are working on production Databricks project using Mleap. when run below code on databricks, it throws error like " 'JavaPackage' object is not callable" code :import mleap.pyspark from mleap.pyspark.spark_support import SimpleSparkSer...
- 6690 Views
- 3 replies
- 1 kudos
- 18026 Views
- 10 replies
- 0 kudos
Resolved! How to convert column type from decimal to date in sparksql
I need to convert column type from decimal to date in sparksql when the format is not yyyy-mm-dd? A table contains column data declared as decimal (38,0) and data is in yyyymmdd format and I am unable to run sql queries on it in databrick notebook. ...
- 18026 Views
- 10 replies
- 0 kudos
- 21226 Views
- 5 replies
- 2 kudos
Resolved! How to display SHAP plots?
I am looking to display SHAP plots, here is the code:import xgboost import shap shap.initjs() # load JS visualization code to notebookX,y = shap.datasets.boston() # train XGBoost model model = xgboost.train({"learning_rate": 0.01}, xgboost.DMatri...
- 21226 Views
- 5 replies
- 2 kudos
- 2 kudos
As @Vinh dqvinh87​ noted, the accepted solution only works for force_plot. For other plots, the following trick works for me:import matplotlib.pyplot as plt p = shap.summary_plot(shap_values, test_df, show=False) display(p)
- 2 kudos
- 16261 Views
- 3 replies
- 0 kudos
KNN classifier on Spark
Hi Team , Can you please help me in implementing KNN classifer in pyspark using distributed architecture and processing the dataset. Even I want to validate the KNN model with the testing dataset. I tried to use scikit learn but the program is runn...
- 16261 Views
- 3 replies
- 0 kudos
- 0 kudos
Hey, about about using NEC Frovedis (https://github.com/frovedis/frovedis) framework for the same. Refer: https://github.com/frovedis/frovedis/blob/master/src/foreign_if/python/examples/unsupervised_knn_demo.py It works on a distributed framework (...
- 0 kudos
- 25586 Views
- 1 replies
- 0 kudos
How can I read all the files in a folder on S3 into several pandas dataframes?
import pandas as pd import glob path = "s3://somewhere/" # use your path all_files = glob.glob(path + "/*.csv") print(all_files) li = [] for filename in all_files: dfi = pd.read_csv(filename,names =['acct_id', 'SOR_ID'], dtype={'acct_id':str,...
- 25586 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @zhaoxuan210, Please go through the below answer,https://stackoverflow.com/questions/52855221/reading-multiple-csv-files-from-s3-bucket-with-boto3
- 0 kudos
- 7206 Views
- 6 replies
- 0 kudos
- 7206 Views
- 6 replies
- 0 kudos
- 0 kudos
Hello, What is most efficient between RDD and DataFrame ? (I mean better to cache, consume less memory) Thanks you,
- 0 kudos
- 45575 Views
- 5 replies
- 3 kudos
What's the difference between Interactive Clusters and Job Cluster?
I am new to databricks. I would like to know what is the difference between Interactive Clusters and Job Cluster? There are no official document now.
- 45575 Views
- 5 replies
- 3 kudos
- 3 kudos
Sports news Football news International football news Football news Thai football news, Thai football Follow news, know sports news at Siamsportnews
- 3 kudos
- 25768 Views
- 9 replies
- 1 kudos
How can I change the parquet compression algorithm from gzip to something else?
Spark, by default, uses gzip to store parquet files. I would like to change the compression algorithm from gzip to snappy or lz4.
- 25768 Views
- 9 replies
- 1 kudos
- 10543 Views
- 1 replies
- 0 kudos
convert string dataframe column MM/dd/yyyy hh:mm:ss AM/PM to timestamp MM-dd-yyyy hh:mm:ss
How to convert string 6/3/2019 5:06:00 AM to timestamp in 24 hour format MM-dd-yyyy hh:mm:ss in python spark.
- 10543 Views
- 1 replies
- 0 kudos
- 0 kudos
You would use a combination of the functions: pyspark.sql.functions.from_unixtime(timestamp, format='yyyy-MM-dd HH:mm:ss') (documentation) and pyspark.sql.functions.unix_timestamp(timestamp=None, format='yyyy-MM-dd HH:mm:ss') (documentation)from pysp...
- 0 kudos
- 9253 Views
- 1 replies
- 0 kudos
How to deal with column name with .(dot) in pyspark dataframe??
We are streaming data from kafka source with json but in some column we are getting .(dot) in column names.streaming json data: df1 = df.selectExpr("CAST(value AS STRING)") {"pNum":"A14","from":"telecom","payload":{"TARGET":"1","COUNTRY":"India"...
- 9253 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @Mithu Wagh you can use backticks to enclose the column name.df.select("`col0.1`")
- 0 kudos
- 7034 Views
- 2 replies
- 0 kudos
Resolved! Saving to parquet with SaveMode.Overwrite throws exception
Hello, I'm trying to save DataFrame in parquet with SaveMode.Overwrite with no success. I minimized the code and reproduced the issue with the following two cells: > case class MyClass(val fld1: Integer, val fld2: Integer) > > val lst1 = sc.paralle...
- 7034 Views
- 2 replies
- 0 kudos
- 0 kudos
results.select("ValidationTable", "Results","Description","CreatedBy","ModifiedBy","CreatedDate","ModifiedDate").write.mode('overwrite').save("
- 0 kudos
- 7216 Views
- 3 replies
- 0 kudos
How to specify multiple files in --py-files in spark-submit command for databricks job? All the files to be specified in --py-files present in dbfs: .
I have created a databricks in azure. I have created a cluster for python 3. I am creating a job using spark-submit parameters. How to specify multiple files in --py-files in spark-submit command for databricks job? All the files to be specified in ...
- 7216 Views
- 3 replies
- 0 kudos
- 0 kudos
Hi @Nandha Kumar,please go through the below docs to pass python files as job,https://docs.databricks.com/dev-tools/api/latest/jobs.html#sparkpythontask
- 0 kudos
- 5349 Views
- 4 replies
- 0 kudos
- 5349 Views
- 4 replies
- 0 kudos
- 0 kudos
@cfregly​ : For DataFrames, you can use the following code for using groupBy without aggregations.Df.groupBy(Df["column_name"]).agg({})
- 0 kudos
| User | Count |
|---|---|
| 1616 | |
| 790 | |
| 469 | |
| 349 | |
| 287 |
