Setting up Dask Distributed Cluster about pangeo-example-notebooks HOT 2 CLOSED

---------------------------------------------------------------------------
KilledWorker                              Traceback (most recent call last)
<ipython-input-22-7b1137e223f8> in <module>()
      1 with ProgressBar():
----> 2     p = p.compute()

/srv/conda/lib/python3.6/site-packages/xarray/core/dataarray.py in compute(self, **kwargs)
    657         """
    658         new = self.copy(deep=False)
--> 659         return new.load(**kwargs)
    660 
    661     def persist(self, **kwargs):

/srv/conda/lib/python3.6/site-packages/xarray/core/dataarray.py in load(self, **kwargs)
    631         dask.array.compute
    632         """
--> 633         ds = self._to_temp_dataset().load(**kwargs)
    634         new = self._from_temp_dataset(ds)
    635         self._variable = new._variable

/srv/conda/lib/python3.6/site-packages/xarray/core/dataset.py in load(self, **kwargs)
    489 
    490             # evaluate all the dask arrays simultaneously
--> 491             evaluated_data = da.compute(*lazy_data.values(), **kwargs)
    492 
    493             for k, data in zip(lazy_data, evaluated_data):

/srv/conda/lib/python3.6/site-packages/dask/base.py in compute(*args, **kwargs)
    396     keys = [x.__dask_keys__() for x in collections]
    397     postcomputes = [x.__dask_postcompute__() for x in collections]
--> 398     results = schedule(dsk, keys, **kwargs)
    399     return repack([f(r, *a) for r, (f, a) in zip(results, postcomputes)])
    400 

/srv/conda/lib/python3.6/site-packages/distributed/client.py in get(self, dsk, keys, restrictions, loose_restrictions, resources, sync, asynchronous, direct, retries, priority, fifo_timeout, actors, **kwargs)
   2336             try:
   2337                 results = self.gather(packed, asynchronous=asynchronous,
-> 2338                                       direct=direct)
   2339             finally:
   2340                 for f in futures.values():

/srv/conda/lib/python3.6/site-packages/distributed/client.py in gather(self, futures, errors, maxsize, direct, asynchronous)
   1660             return self.sync(self._gather, futures, errors=errors,
   1661                              direct=direct, local_worker=local_worker,
-> 1662                              asynchronous=asynchronous)
   1663 
   1664     @gen.coroutine

/srv/conda/lib/python3.6/site-packages/distributed/client.py in sync(self, func, *args, **kwargs)
    674             return future
    675         else:
--> 676             return sync(self.loop, func, *args, **kwargs)
    677 
    678     def __repr__(self):

/srv/conda/lib/python3.6/site-packages/distributed/utils.py in sync(loop, func, *args, **kwargs)
    275             e.wait(10)
    276     if error[0]:
--> 277         six.reraise(*error[0])
    278     else:
    279         return result[0]

/srv/conda/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)
    691             if value.__traceback__ is not tb:
    692                 raise value.with_traceback(tb)
--> 693             raise value
    694         finally:
    695             value = None

/srv/conda/lib/python3.6/site-packages/distributed/utils.py in f()
    260             if timeout is not None:
    261                 future = gen.with_timeout(timedelta(seconds=timeout), future)
--> 262             result[0] = yield future
    263         except Exception as exc:
    264             error[0] = sys.exc_info()

/srv/conda/lib/python3.6/site-packages/tornado/gen.py in run(self)
   1053 
   1054                     try:
-> 1055                         value = future.result()
   1056                     except Exception:
   1057                         self.had_exception = True

/srv/conda/lib/python3.6/site-packages/tornado/concurrent.py in result(self, timeout)
    236         if self._exc_info is not None:
    237             try:
--> 238                 raise_exc_info(self._exc_info)
    239             finally:
    240                 self = None

/srv/conda/lib/python3.6/site-packages/tornado/util.py in raise_exc_info(exc_info)

/srv/conda/lib/python3.6/site-packages/tornado/gen.py in run(self)
   1061                     if exc_info is not None:
   1062                         try:
-> 1063                             yielded = self.gen.throw(*exc_info)
   1064                         finally:
   1065                             # Break up a reference to itself

/srv/conda/lib/python3.6/site-packages/distributed/client.py in _gather(self, futures, errors, direct, local_worker)
   1501                             six.reraise(type(exception),
   1502                                         exception,
-> 1503                                         traceback)
   1504                     if errors == 'skip':
   1505                         bad_keys.add(key)

/srv/conda/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)
    691             if value.__traceback__ is not tb:
    692                 raise value.with_traceback(tb)
--> 693             raise value
    694         finally:
    695             value = None

KilledWorker: ('zarr-e520da87e7d8be3d8042ca551debc946', 'tcp://10.48.180.35:37959')