Not sure what you try to do, but the result is correct.

Scenario 2:

Partition 1 ("12", "23")
("","12") => "0"
("0","23") => "1"

Partition 2 ("","345")
("","") => "0"
("0","345") => "1"

Final merge:
("1","1") => "11"




On Mon, Dec 28, 2015 at 7:14 AM, Prem Spark <sparksure...@gmail.com> wrote:

> Scenario1:
> val z = sc.parallelize(List("12","23","345",""),2)
> z.aggregate("")((x,y) => math.min(x.length, y.length).toString, (x,y) => x
> + y)
> res143: String = 10
>
> Scenario2:
> val z = sc.parallelize(List("12","23","","345"),2)
> z.aggregate("")((x,y) => math.min(x.length, y.length).toString, (x,y) => x
> + y)
> res144: String = 11
>
> why the result is different . I was expecting 10 for both. also for the
> first Partition
>



-- 
Best Regards

Jeff Zhang

Reply via email to