Try without the *
val avroRdd = sc.newAPIHadoopFile("hdfs://<url>:8020/<my dir>/",
classOf[AvroSequenceFileInputFormat[AvroKey[GenericRecord],NullWritable]],
classOf[AvroKey[GenericRecord]], classOf[NullWritable])
avroRdd.collect()
Thanks
Best Regards
On Fri, Jul 25, 2014 at 7:22 PM, Sparky <gullo_tho...@bah.com> wrote:
> I'm pretty sure my problem is related to this unresolved bug regarding
> files
> with size zero:
>
> https://issues.apache.org/jira/browse/SPARK-1960
>
>
>
> --
> View this message in context:
> http://apache-spark-user-list.1001560.n3.nabble.com/EOFException-when-I-list-all-files-in-hdfs-directory-tp10648p10649.html
> Sent from the Apache Spark User List mailing list archive at Nabble.com.
>
