Please file an issue: Spark Project
JIRA<https://issues.apache.org/jira/browse/SPARK>



On Fri, Apr 18, 2014 at 10:25 AM, Aureliano Buendia <buendia...@gmail.com>wrote:

> Hi,
>
> I just notices that sc.makeRDD() does not make all values given with input
> type of NumericRange, try this in spark shell:
>
>
> $ MASTER=local[4] bin/spark-shell
>
> scala> sc.makeRDD(0.0 to 1 by 0.1).collect().length
>
> *8*
>
>
> The expected length is 11. This works correctly when lanching spark with
> only one core:
>
>
> $ MASTER=local[1] bin/spark-shell
>
> scala> sc.makeRDD(0.0 to 1 by 0.1).collect().length
>
> *11*
>
>
> This also works correctly when using toArray():
>
> $ MASTER=local[4] bin/spark-shell
>
> scala> sc.makeRDD((0.0 to 1 by 0.1).*toArray*).collect().length
>
> *8*
>

Reply via email to