我将新节点添加到 dask 集群并使用 conda 安装了所有依赖项。安装在所有 dask 节点上的包和版本方面都相似。
但是,新节点上的任务失败并出现以下错误:
ModuleNotFoundError: No module named 'parquet_thrift'
[worker ....]:distributed.worker - 警告 - 无法反序列化任务
所有其他节点工作正常。仅供参考:所有节点都安装了快速镶木地板。
如果我遗漏了什么,请告诉我。
我将新节点添加到 dask 集群并使用 conda 安装了所有依赖项。安装在所有 dask 节点上的包和版本方面都相似。
但是,新节点上的任务失败并出现以下错误:
ModuleNotFoundError: No module named 'parquet_thrift'
[worker ....]:distributed.worker - 警告 - 无法反序列化任务
所有其他节点工作正常。仅供参考:所有节点都安装了快速镶木地板。
如果我遗漏了什么,请告诉我。