本地 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)
当 运行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)