本地 Dask worker 无法连接到本地调度程序

Local Dask worker unable to connect to local scheduler

当 运行ning Dask 0.16.0 在 OSX 10.12.6 上时,我无法将本地 dask-worker 连接到本地 dask-scheduler。我只是想关注一下官方Dask tutorial。重现步骤:

第 1 步: 运行 dask-scheduler

第 2 步: 运行 dask-worker 10.160.39.103:8786

这个问题似乎与 dask scheduler 有关,而不是 worker,因为我什至无法通过其他方式访问端口(例如,nc -zv 10.160.39.103 8786)。

但是,进程显然还在机器上 运行ning:

我的第一个猜测是,由于网络规则,您的计算机可能不接受看起来像是来自外部世界的网络连接。您可能想尝试使用 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

作为万无一失的方法,您还可以通过 processes=False 这将完全避免网络问题

client = Client(processes=False)