Closed
Description
Observation made in relation to #1179.
Running a local distributed executor like in the "hello world" example crashes if the allocator is jemalloc.
Starting an IPython shell via LD_PRELOAD=/usr/lib/libjemalloc.so.1 ipython and running the following code
from dask.distributed import Client
client = Client()
def square(x):
return x ** 2
def neg(x):
return -x
A = client.map(square, range(10))
B = client.map(neg, A)
total = client.submit(sum, B)
print(total.result())crashes with ValueError: Worker not started
The code works fine using glibc.
Metadata
Metadata
Assignees
Labels
No labels