我在 Kubernetes 命名空间中运行 Dask Gateway。我可以使用以下代码连接到网关,而不是在 Docker 容器中运行。
from dask.distributed import Client
from dask_gateway import Gateway
gateway = Gateway('http://[redacted traefik ip]')
cluster = gateway.new_cluster()
但是,当我从 Docker 容器运行相同的代码时,在gateway.new_cluster()
.
distributed.comm.tcp - WARNING - Closing dangling stream in <TLS local=tls://[local ip]:51060 remote=gateway://[redacted ip]:80/dask-gateway.e71c345decde470e8f9a23c3d5a64956>
这是什么原因?我也尝试--net=host
在 Docker 容器上运行它,这导致了同样的错误。
附加信息:这似乎不是 Docker 网络问题...我可以在 Docker 容器中使用 Coiled 集群,但不能使用 Dask-Gateway 集群...
从 docker 容器到 traefik pod 的初始传出连接似乎成功了。dask-scheduler 在集群中成功启动。但是,连接断开(超时?)会阻止进一步的交互。