【发布时间】:2018-10-24 07:29:29
【问题描述】:
我有一个数据流作业无法启动工作人员并出现以下错误:
File "/usr/lib/python2.7/runpy.py", line 174, in _run_module_as_main "__main__", fname, loader, pkg_name)
File "/usr/lib/python2.7/runpy.py", line 72, in _run_code exec code in run_globals
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/start.py", line 28, in <module>
from dataflow_worker import batchworker
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 57, in <module>
from apache_beam.runners.dataflow.internal.dependency import _dependency_file_copy
ImportError: No module named dependency
但是我可以在另一台机器上使用完全相同的代码(同样的 setup.py 文件)成功运行相同的作业,但我怀疑数据流项目的配置存在问题。
【问题讨论】:
标签: google-cloud-platform google-cloud-dataflow