Re: Updating spark-env.sh per application

2021-05-08 Thread Renu Yadav
Hi Mich, In spark-env.sh , SPARK_DIST_CLASSPATH is set . I want to override this variable during runtime as wanted to exclude one lib class from it. On Fri, 7 May, 2021, 6:51 pm Mich Talebzadeh, wrote: > Hi, > > Environment variables Re read in when spark-submit kicks off. What exactly > you

How to have map_from_arrays() in Spark 2.3

2021-05-08 Thread Sebastian Schere
I have the following Dataframe in Spark 2.3, coming from a JSON file: root |-- ext_attr: array (nullable = true) ||-- element: struct (containsNull = true) |||-- key: string (nullable = true) |||-- value: string (nullable = true) I would need to convert it to below

Re: Issue while calling foreach in Pyspark

2021-05-08 Thread Sean Owen
It looks like the executor (JVM) stops immediately. Hard to say why - do you have Java installed and a compatible version? I agree it could be a py4j version problem, from that SO link. On Sat, May 8, 2021, 1:35 PM rajat kumar wrote: > Hi Sean/Mich, > > Thanks for response. > > That was the

Re: Issue while calling foreach in Pyspark

2021-05-08 Thread rajat kumar
Hi Sean/Mich, Thanks for response. That was the full log. Sending again for reference. I am just running foreach (lamda) which runs pure python code. Exception in read_logs : Py4JJavaError Traceback (most recent call last): File "/opt/spark/python/lib/python3.6/site-packages/filename.py",