dask - Dask 'distributed.comm.tcp - INFO - 握手完成前连接关闭'

Question

我在我的 K8s 集群中部署了一个 Dask 服务，其中一个调度器、三个工作器和一个连接到调度器的客户端。当我连接到调度程序 ( kubectl attach <my-scheduler-pod>) 时，我会收到持续的标准输出消息，其中包括：

distributed.comm.tcp - INFO - Connection closed before handshake completed

这会每六秒左右显示四条消息。这四条消息彼此非常接近。据我所知，这不会对任何事情产生不利影响——我的服务正在运行——但消息本身以及持续的性质似乎并不是一件好事。

如果有的话，我应该怎么做？

标签： daskdask-distributed

Answer 1

这是因为 dash schedular 在不同的 dask 版本上运行

from distributed.versions import get_versions
get_versions()

我在本地复制了同样的问题 我的 dask schedular 在 dask 2021.01.0 上运行，而我的客户使用 2021.0.1.03

Dask时间表：- {'host': {'python': '3.8.0.final.0', 'python-bits': 64, 'OS': 'Linux', 'OS-release': '4.14.209-160.339.amzn2.x86_64', 'machine': 'x86_64', 'processor': '', 'byteorder': 'little', 'LC_ALL': 'C.UTF-8', 'LANG': 'C.UTF-8'}, 'packages': {'python': '3.8.0.final.0', 'dask': '2021.01.0', 'distributed': '2021.01.0', 'msgpack': '1.0.0', 'cloudpickle': '1.6.0', 'tornado': '6.1', 'toolz': '0.11.1', 'numpy': '1.18.1', 'lz4': '3.1.1', 'blosc': '1.9.2'}}

客户：- {'host': {'python': '3.7.10.final.0', 'python-bits': 64, 'OS': 'Linux', 'OS-release': '4.14.214-160.339.amzn2.x86_64', 'machine': 'x86_64', 'processor': '', 'byteorder': 'little', 'LC_ALL': 'C.UTF-8', 'LANG': 'C.UTF-8'}, 'packages': {'python': '3.7.10.final.0', 'dask': '2021.03.0', 'distributed': '2021.03.0', 'msgpack': '1.0.2', 'cloudpickle': '1.6.0', 'tornado': '6.1', 'toolz': '0.11.1', 'numpy': None, 'lz4': None, 'blosc': None}

确保两者都运行相同的版本