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