dask / dask/distributed

Tasks are not uniformly distributed across Dask workers

Open
#7,093 1 comment 0 reactions 0 assignees View on GitHub
needs info
Dominant language
Python
Stars
1.7k
Forks
778
Avg merge
2h 50m
Merged PRs (30d)
3

Description

**Describe the issue**:
Tasks are not uniformly distributed across all the available dask workers. The majority of the tasks, are getting piled up on a single worker. Is this an expected behavior?

![Dask-Status](https://user-images.githubusercontent.com/10769536/193209069-124e1427-fbeb-418c-839c-21b95116107e.png)

![Workers](https://user-images.githubusercontent.com/10769536/193209111-8cb07148-d4be-424f-a1d3-fd51305716ac.png)

**Anything else we need to know?**:
The cluster is adaptive and the rest of the workers were added after 1-2 minutes. **Why the pending tasks are not getting routed to the new workers?**

**Environment**:

- Dask version: 2.30.0
- Distributed version: 2.30.1
- Python version: 3.7.10
- Operating System: CentOS Linux 7 (Core)
- Install method (conda, pip, source): pip

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.