use*_*481 4 dask dask-distributed
在 OSX 10.12.6 上运行 Dask 0.16.0 时,我无法将本地连接dask-worker到本地dask-scheduler. 我只是想遵循官方Dask 教程。重现步骤:
第 1 步:运行dask-scheduler
第 2 步:运行dask-worker 10.160.39.103:8786
该问题似乎与 dask 调度程序有关,而不是与工作人员有关,因为我什至无法通过其他方式访问该端口(例如nc -zv 10.160.39.103 8786)。
然而,该进程显然仍在机器上运行:
我的第一个猜测是,由于网络规则,您的计算机可能不接受看起来来自外部世界的网络连接。您可能想尝试使用dask-worker localhost:8786并看看是否有效。
另外,提醒一下,您始终可以直接从 Python 启动调度程序和工作线程,而无需创建 dask-scheduler 和 dask-worker 进程
from dask.distributed import Client
# client = Client('scheduler-address:8786')
client = Client() # create scheduler and worker automatically
Run Code Online (Sandbox Code Playgroud)
作为一种万无一失的方法,您也可以通过processes=False,这将完全避免网络问题
client = Client(processes=False)
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
2509 次 |
| 最近记录: |