You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Kyle Weaver (JIRA)" <ji...@apache.org> on 2019/04/10 23:21:00 UTC

[jira] [Created] (BEAM-7052) wordcount.py raises IOError on portable runner

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)