Reductions do not properly support unstructured distributions

Aperta
#659 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
4/5
Tempo stimato
3-5 giorni
Idoneità per principianti
42/100
Tipo di issue
Bug
Chiarezza
Abbastanza chiara
Stato di attività
Ferma
Stack tecnologico
python
Ambito
distributed-systems

Direzione di ricerca

Esegui la riproduzione fornita di IPython.parallel con dacluster start -n4, quindi traccia distarray/globalapi/distarray.py attraverso _reduce e distarray/globalapi/maps.py attraverso Distribution.reduce, get_dim_data_per_rank e UnstructuredMap.get_dimdicts. L'attività è completata quando darr.sum(axis=1) viene eseguito correttamente e gli indici di input non strutturati vengono propagati alla distribuzione di output.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

This reproduces the problem

# Using IPython.parallel: 'dacluster start -n4' before running.
import numpy as np
from distarray.globalapi import Context
from distarray.globalapi.maps import Distribution, NoDistMap, UnstructuredMap

nparr = np.random.rand(4, 5)

context = Context()
m0 = UnstructuredMap(4, 3, [[0], [1], [2, 3]])
m1 = NoDistMap(5, 1)
distribution = Distribution.from_maps(
    context,
    maps=[m0, m1],
    targets=[0, 1, 3]
)

darr = context.fromarray(nparr, distribution)
from IPython.core.debugger import Tracer; Tracer()()
darr.sum(axis=1)  # boom!

This results in

Traceback (most recent call last):
  File "failure.py", line 19, in <module>
    darr.sum(axis=1)  # boom!
  File "/Users/cfarrow/projects/distarray/distarray/globalapi/distarray.py", line 383, in sum
    return self._reduce('sum_reducer', axis, dtype, out)
  File "/Users/cfarrow/projects/distarray/distarray/globalapi/distarray.py", line 362, in _reduce
    ddpr = out_dist.get_dim_data_per_rank()
  File "/Users/cfarrow/projects/distarray/distarray/globalapi/maps.py", line 830, in get_dim_data_per_rank
    dds = [enumerate(m.get_dimdicts()) for m in self.maps]
  File "/Users/cfarrow/projects/distarray/distarray/globalapi/maps.py", line 510, in get_dimdicts
    raise ValueError()
ValueError

Distribution.reduce does not appear to consider UnstructuredMap, which leads to the indices used by the input UnstructuredMap to not be propagated to the output UnstructuredMap.

Lingua principale
Python
Stelle
5
Fork
1
Nessuna PR unita negli ultimi 30g

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di enthought/distarray

Tutte le issue di enthought/distarray

Issue simili

Altre issue su Python

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.