Could you try with specify PYSPARK_PYTHON to the path of python in your virtual env, for example
PYSPARK_PYTHON=/path/to/env/bin/python bin/spark-submit xx.py On Mon, Apr 20, 2015 at 12:51 AM, Karlson <[email protected]> wrote: > Hi all, > > I am running the Python process that communicates with Spark in a > virtualenv. Is there any way I can make sure that the Python processes of > the workers are also started in a virtualenv? Currently I am getting > ImportErrors when the worker tries to unpickle stuff that is not installed > system-wide. For now both the worker and the driver run on the same machine > in local mode. > > Thanks in advance! > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
