Kyle Weaver created BEAM-7052:
---------------------------------
Summary: wordcount.py raises IOError on portable runner
Key: BEAM-7052
URL: https://issues.apache.org/jira/browse/BEAM-7052
Project: Beam
Issue Type: Improvement
Components: sdk-py-core
Reporter: Kyle Weaver
Assignee: Kyle Weaver
Got this error when trying to run wordcount.py against the Spark portable
runner:
{{RuntimeError: IOError: [Errno 2] No such file or directory:
'/tmp/beam-temp-py-wordcount-direct-a9e7beba888211e8843d025000000001/44ba0386-4221-4abc-ae8d-5a2aa4610c4f.py-wordcount-direct'
[while running 'write/Write/WriteImpl/WriteBundles']}}
This does not seem to be an issue with Flink (maybe because of
environment_cache_millis), but in any case the problem is fixed when I set
--environment_type=LOOPBACK.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
