SparkContext addFile 导致 FileNotFoundException

Question

我正在尝试使用 sparkContext.addFile 方法将大文件传送给每个执行者。

这个大文件的来源是 Amazon S3（注意：如果来源是 HDFS，一切正常）

val context = stream.context.sparkContext
context.addFile("s3n://bucket-name/file-path")
...
SparkFiles.get(file-name)

这是错误的原因：

java.io.FileNotFoundException: File s3n://bucket-name/file-path does not exist.
    at com.amazon.ws.emr.hadoop.fs.s3n.S3NativeFileSystem.listStatus(S3NativeFileSystem.java:945)
    at com.amazon.ws.emr.hadoop.fs.s3n.S3NativeFileSystem.listStatus(S3NativeFileSystem.java:887)
    at com.amazon.ws.emr.hadoop.fs.EmrFileSystem.listStatus(EmrFileSystem.java:343)
    at org.apache.spark.util.Utils$.fetchHcfsFile(Utils.scala:596)
    at org.apache.spark.util.Utils$.doFetchFile(Utils.scala:566)
    at org.apache.spark.util.Utils$.fetchFile(Utils.scala:356)
    at org.apache.spark.executor.Executor$$anonfun$org$apache$spark$executor$Executor$$updateDependencies.apply(Executor.scala:393)
    at org.apache.spark.executor.Executor$$anonfun$org$apache$spark$executor$Executor$$updateDependencies.apply(Executor.scala:390)
    at scala.collection.TraversableLike$WithFilter$$anonfun$foreach.apply(TraversableLike.scala:772)
    at scala.collection.mutable.HashMap$$anonfun$foreach.apply(HashMap.scala:98)
    at scala.collection.mutable.HashMap$$anonfun$foreach.apply(HashMap.scala:98)
    at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:226)
    at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39)
    at scala.collection.mutable.HashMap.foreach(HashMap.scala:98)
    at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
    at org.apache.spark.executor.Executor.org$apache$spark$executor$Executor$$updateDependencies(Executor.scala:390)
    at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:193)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)

但是当我这样做时 "fs -ls"，文件是可访问的

    hadoop fs -ls s3n://bucket-name/file-path

可能是什么原因？

PS：星火版本：1.5.2

Answer 1

突然间，这是凭据问题。当我将 s3 URL 更改为

  s3n://accessKey:secretKey@backet-name/path

问题已解决。

SparkContext addFile 导致 FileNotFoundException

SparkContext addFile causes FileNotFoundException

apache-spark

amazon-s3

emr

amazon-emr