问题描述
我正在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>
这是什么原因?我还尝试在Docker容器上使用--net=host
来运行它,这导致了相同的错误。
其他信息:这似乎不是Docker网络问题...我可以从Docker容器中使用Coiled群集,但不能使用Dask-Gateway群集。
似乎从docker容器到traefik pod的初始传出连接成功。调度程序已成功在集群中启动。但是,连接断开(超时?)阻止了进一步的交互。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)