0

我正在使用 dask-client submit api 运行多个并发 dask 作业。它已经多次遇到这个问题。

特定工作者的线程转储显示以下信息。

有人可以指导我解决这个问题。

ts_data = dask_df[key].values.compute()
  文件“/agent/miniconda3/envs/py361/lib/python3.6/site-packages/dask/base.py”，第 135 行，在计算中
    (结果,) = 计算(self, traverse=False, **kwargs)
  计算中的文件“/agent/miniconda3/envs/py361/lib/python3.6/site-packages/dask/base.py”，第 333 行
    结果 = 获取（dsk，键，**kwargs）
  文件“/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/client.py”，第 1999 行，在 get
    结果 = self.gather（打包，异步=异步）
  文件“/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/client.py”，第 1437 行，聚集
    异步=异步）
  文件“/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/client.py”，第 592 行，同步
    返回同步（self.loop，func，*args，**kwargs）
  文件“/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/utils.py”，第 252 行，同步
    e.wait(1000000)
  文件“/agent/miniconda3/envs/py361/lib/python3.6/threading.py”，第 551 行，等待中
    信号 = self._cond.wait（超时）
  文件“/agent/miniconda3/envs/py361/lib/python3.6/threading.py”，第 299 行，等待中
    gotit = waiter.acquire(True, timeout)
4

0 回答 0