ers. perhaps you want to use map instead, and then
>> collect the failed file names locally, or save the whole thing out to a file
>>
>> From: Marius Soutier [mps@gmail.com]
>> Sent: Friday, October 24, 2014 6:35 AM
>> To: user@spa
ed file names locally, or save the whole thing out to a file
>
> From: Marius Soutier [mps@gmail.com]
> Sent: Friday, October 24, 2014 6:35 AM
> To: user@spark.apache.org
> Subject: scala.collection.mutable.ArrayOps$ofRef$.length$extension since
&g
Hi,
I’m running a job whose simple task it is to find files that cannot be read
(sometimes our gz files are corrupted).
With 1.0.x, this worked perfectly. Since 1.1.0 however, I’m getting an
exception:
scala.collection.mutable.ArrayOps$ofRef$.length$extension(ArrayOps.scala:114)
sc.wholeT
