JuliaParallel / JuliaParallel/DistributedArrays.jl

ddata doesn't work as intended when length(data) = length(pids)

オープン
#239 コメント 0 件 リアクション 1 件 担当者 0 名 GitHub で見る
主要言語
Julia
スター
205
フォーク
34
PR マージ指標
30日以内にマージされた PR はありません

説明

The documentation says the following about `ddata`:

> The function `ddata(;T::Type=Any, init::Function=I->nothing, pids=workers(), data::Vector=[])` can be used to created a distributed vector whose localparts need not be Arrays.
> ...
> Argument `data` if supplied is distributed over the `pids`. `length(data)` must be a multiple of `length(pids)`. **If the multiple is 1, returns a `DArray{T,1,T}` where T is `eltype(data)`**. If the multiple is greater than 1, returns a `DArray{T,1,Array{T,1}}`, i.e., it is equivalent to calling `distribute(data)`.

The case when "_the multiple is 1_" is giving me trouble:

```Julia
julia> using Distributed; addprocs(2)
julia> using DistributedArrays

julia> ddata(data=["foo", "bar"])

2-element DArray{String, 1, String}:
ERROR: TypeError: in typeassert, expected String, got a value of type Char
...
```
```Julia
julia> ddata()

ERROR: On worker 2:
MethodError: no method matching getindex(::Nothing, ::Int64)
...
```

Note that `ddata` works as intended for multiples greater than 1:

```julia
julia> ddata(data=["foo", "bar", "foo", "bar"])

4-element DArray{String, 1, Vector{String}}:
"foo"
"bar"
"foo"
"bar"
```

```julia
julia> ddata(;T=Any, init=I->nothing, pids=workers(), data=[nothing, nothing, nothing, nothing])

4-element DArray{Nothing, 1, Vector{Nothing}}:
nothing
nothing
nothing
nothing
```

First time posting an issue, hope I'm doing things right!

コントリビューションガイド

このリポジトリのコントリビューションガイドは索引されていません

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。