[
https://issues.apache.org/jira/browse/BEAM-6158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mark Liu updated BEAM-6158:
---------------------------
Description:
This happened when I run wordcount example with portable Dataflow runner in
Python 3.5. The failure shows in worker log (unfortunately unformatted) of
[this
job|https://pantheon.corp.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-11-29_11_47_38-6731484595556255542?project=google.com:clouddfe]:
{code:java}
Could not load main session: Traceback (most recent call last): File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 125, in main _load_main_session(semi_persistent_directory) File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 201, in _load_main_session pickler.load_session(session_file) File
"/usr/local/lib/python3.5/site-packages/apache_beam/internal/pickler.py", line
269, in load_session return dill.load_session(file_path) File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 402, in
load_session module = unpickler.load() File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 465, in find_class
return StockUnpickler.find_class(self, module, name) AttributeError: Can't get
attribute 'WordExtractingDoFn' on <module
'apache_beam.runners.worker.sdk_worker_main' from
'/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py'>
Traceback (most recent call last): File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 125, in main _load_main_session(semi_persistent_directory) File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 201, in _load_main_session pickler.load_session(session_file) File
"/usr/local/lib/python3.5/site-packages/apache_beam/internal/pickler.py", line
269, in load_session return dill.load_session(file_path) File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 402, in
load_session module = unpickler.load() File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 465, in find_class
return StockUnpickler.find_class(self, module, name) AttributeError: Can't get
attribute 'WordExtractingDoFn' on <module
'apache_beam.runners.worker.sdk_worker_main' from
'/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py'>
{code}
Looks like saved main session didn't work properly in Python 3.
+cc: [~tvalentyn] [~robertwb] [~altay]
was:
This happened when I run wordcount example with portable Dataflow runner in
Python 3.5. The failure shows in worker log (unfortunately unformatted) of
[this
job|https://pantheon.corp.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-11-29_11_47_38-6731484595556255542?project=google.com:clouddfe]:
{code}
Could not load main session: Traceback (most recent call last): File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 125, in main _load_main_session(semi_persistent_directory) File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 201, in _load_main_session pickler.load_session(session_file) File
"/usr/local/lib/python3.5/site-packages/apache_beam/internal/pickler.py", line
269, in load_session return dill.load_session(file_path) File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 402, in
load_session module = unpickler.load() File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 465, in find_class
return StockUnpickler.find_class(self, module, name) AttributeError: Can't get
attribute 'WordExtractingDoFn' on <module
'apache_beam.runners.worker.sdk_worker_main' from
'/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py'>
Traceback (most recent call last): File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 125, in main _load_main_session(semi_persistent_directory) File
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 201, in _load_main_session pickler.load_session(session_file) File
"/usr/local/lib/python3.5/site-packages/apache_beam/internal/pickler.py", line
269, in load_session return dill.load_session(file_path) File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 402, in
load_session module = unpickler.load() File
"/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 465, in find_class
return StockUnpickler.find_class(self, module, name) AttributeError: Can't get
attribute 'WordExtractingDoFn' on <module
'apache_beam.runners.worker.sdk_worker_main' from
'/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py'>
{code}
In order to get this error, I need to patch few type error fixes first
([PR-7051|https://github.com/apache/beam/pull/7051] and
[PR-4|https://github.com/markflyhigh/incubator-beam/pull/4]).
Looks like saved main session didn't work properly in Python 3. A recent
[PR-7104|https://github.com/apache/beam/pull/7104] mentioned [an
error|https://github.com/uqfoundation/dill/pull/294] in dill probably related
to this problem but I didn't verify yet.
+cc: [~tvalentyn] [~robertwb] [~altay]
> Worker failed with save_main_session enabled on Dataflow in Python 3
> --------------------------------------------------------------------
>
> Key: BEAM-6158
> URL: https://issues.apache.org/jira/browse/BEAM-6158
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-harness
> Reporter: Mark Liu
> Assignee: Robert Bradshaw
> Priority: Major
>
> This happened when I run wordcount example with portable Dataflow runner in
> Python 3.5. The failure shows in worker log (unfortunately unformatted) of
> [this
> job|https://pantheon.corp.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-11-29_11_47_38-6731484595556255542?project=google.com:clouddfe]:
> {code:java}
> Could not load main session: Traceback (most recent call last): File
> "/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
> line 125, in main _load_main_session(semi_persistent_directory) File
> "/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
> line 201, in _load_main_session pickler.load_session(session_file) File
> "/usr/local/lib/python3.5/site-packages/apache_beam/internal/pickler.py",
> line 269, in load_session return dill.load_session(file_path) File
> "/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 402, in
> load_session module = unpickler.load() File
> "/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 465, in
> find_class return StockUnpickler.find_class(self, module, name)
> AttributeError: Can't get attribute 'WordExtractingDoFn' on <module
> 'apache_beam.runners.worker.sdk_worker_main' from
> '/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py'>
> Traceback (most recent call last): File
> "/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
> line 125, in main _load_main_session(semi_persistent_directory) File
> "/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
> line 201, in _load_main_session pickler.load_session(session_file) File
> "/usr/local/lib/python3.5/site-packages/apache_beam/internal/pickler.py",
> line 269, in load_session return dill.load_session(file_path) File
> "/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 402, in
> load_session module = unpickler.load() File
> "/usr/local/lib/python3.5/site-packages/dill/_dill.py", line 465, in
> find_class return StockUnpickler.find_class(self, module, name)
> AttributeError: Can't get attribute 'WordExtractingDoFn' on <module
> 'apache_beam.runners.worker.sdk_worker_main' from
> '/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/sdk_worker_main.py'>
> {code}
> Looks like saved main session didn't work properly in Python 3.
> +cc: [~tvalentyn] [~robertwb] [~altay]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
