Hello all,
Can anyone offer any insight on the below?
Both are legal Spark but the first one works, the latter one does not.
They both work on a local machine but in a standalone cluster the one
with countByValue fails.
Thanks!
Ognen
On 7/15/14, 2:23 PM, Ognen Duzlevski wrote:
Hello,
I
Hello,
I am curious about something:
val result = for {
(dt,evrdd) - evrdds
val ct = evrdd.count
} yield (dt-ct)
works.
val result = for {
(dt,evrdd) - evrdds
val ct = evrdd.countByValue
} yield (dt-ct)
does not work. I get:
14/07/15 16:46:33 WARN
