Pankaj Sharma created BEAM-6752:
-----------------------------------
Summary: Running apache beam dataflow pipeline throwing error:
ImportError: No module named gunicorn.app.wsgiapp
Key: BEAM-6752
URL: https://issues.apache.org/jira/browse/BEAM-6752
Project: Beam
Issue Type: Bug
Components: beam-model, runner-dataflow
Reporter: Pankaj Sharma
I have created app-engine cron jobs to run python flask app which calls
dataflow beam pipeline to ingest data into bigquery.
Traceback (most recent call last): File
"/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line
766, in run self._load_main_session(self.local_staging_directory) File
"/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line
482, in _load_main_session pickler.load_session(session_file) File
"/usr/local/lib/python2.7/dist-packages/apache_beam/internal/pickler.py", line
254, in load_session return dill.load_session(file_path) File
"/usr/local/lib/python2.7/dist-packages/dill/dill.py", line 363, in
load_session module = unpickler.load() File "/usr/lib/python2.7/pickle.py",
line 864, in load dispatchkey File "/usr/lib/python2.7/pickle.py", line 1096,
in load_global klass = self.find_class(module, name) File
"/usr/local/lib/python2.7/dist-packages/dill/dill.py", line 423, in find_class
return StockUnpickler.find_class(self, module, name) File
"/usr/lib/python2.7/pickle.py", line 1130, in find_class *import*(module)
ImportError: No module named gunicorn.app.wsgiapp
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
