Sorry for the delay on this. The problem is that our RecordLoader elects things to come from the file system rather than from S3. Going to take a look around to see if there's any kind of workaround..

Great thanks Ian

I just pushed a commit to branch s3 to allow access to data in S3. It was a matter of modifying the POM to include a dependency on hadoop-aws, and modifying the exclude rules.

@obrienben's above example works now. with one addition – the line:

sc.hadoopConfiguration.set("fs.defaultFS", "s3a://<my-bucket>") // UPDATE: unnecessary

I'll look into making this unnecessary by changing how FileSystem.get() is called.

A few notes:

The version of hadoop-aws used must be identical with hadoop-common. This limits our S3 functionality, as there have been important improvement to the AWS code since 2.6.5, which is our current Hadoop version. I came across two:

• Some S3 endpoints only use what's called Signature Version 4 for authentication, while others use Versions 2 and 4. hadoop-aws 2.6.5 can only handle Version 2. If your S3 store is on an endpoint that uses only Version 4 you're out of luck, unless in pom.xml you change hadoop.version to a (recent?) 2.7 release (I tested 2.7.7). This builds successfully. I tried a 2.8 release, but it resulted in a runtime error.

If you need to use Version 4, you'll have to add these lines to your code (change the ca-central-1 string as appropriate) (credit):

System.setProperty("com.amazonaws.services.s3.enableV4", "true")
sc.hadoopConfiguration.set("com.amazonaws.services.s3.enableV4", "true")
sc.hadoopConfiguration.set("fs.s3a.endpoint", "s3.ca-central-1.amazonaws.com")

• Support for temporary credentials, as provided by an AWS Educate Starter Account, was apparently only introduced with Hadoop 2.8. Upgrading our Hadoop dependencies is nontrivial. When it eventually happens, use of temporary credentials involves setting fs.s3a.aws.credentials.provider to org.apache.hadoop.fs.s3a.TemporaryAWSCredentialsProvider, and setting fs.s3a.session.token to the session token.

Updated above comment to reflect 5cab57b

@obrienben can you pull down that branch, build it, and test it?

Couldn't help myself and wanted to test. Worked flawlessly out of the box on us-west-2, @jrwiebe!

and then

import io.archivesunleashed._
import io.archivesunleashed.matchbox._
r: Array[(String, Int)] = Array((www.equalvoice.ca,4644), (www.liberal.ca,1968), (greenparty.ca,732), (www.policyalternatives.ca,601), (www.fairvote.ca,465), (www.ndp.ca,417), (www.davidsuzuki.org,396), (www.canadiancrc.com,90), (www.gca.ca,40), (communist-party.ca,39))

The right results! If this works on @obrienben's front let's move to a PR?