Need to set
os.environ["PYSPARK_PYTHON"] = "/home/ubuntu/anaconda3/bin/python"
In my local Jupyter where PYSPARK_PYTHON is of worker machines.
Otherwise it takes my sys.executable to cluster and i get error from workers stating python file not found.