dask-client submit api を使用して、複数の同時 dask ジョブを実行しています。この問題は何度も発生しています。
特定のワーカーのスレッド ダンプには、以下の情報が表示されます。
この問題について誰かが私を案内してくれますか。
ts_data = dask_df[キー].values.compute()
ファイル「/agent/miniconda3/envs/py361/lib/python3.6/site-packages/dask/base.py」、135 行目、コンピューティング
(result,) = compute(self, traverse=False, **kwargs)
ファイル「/agent/miniconda3/envs/py361/lib/python3.6/site-packages/dask/base.py」、333 行目、コンピューティング
results = get(dsk, keys, **kwargs)
ファイル「/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/client.py」、1999 行目、get
results = self.gather(パックされた、非同期=非同期)
ファイル "/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/client.py"、1437 行目、gather 内
非同期=非同期)
ファイル「/agent/miniconda3/envs/py361/lib/python3.6/site-packages/distributed/client.py」、592 行目、同期中
return sync(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(真、タイムアウト)