spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Steve Loughran <>
Subject Re: Spark, S3A, and 503 SlowDown / rate limit issues
Date Wed, 12 Jul 2017 17:56:21 GMT

On 10 Jul 2017, at 21:57, Everett Anderson <<>>


Thanks for the responses, guys!

On Thu, Jul 6, 2017 at 7:08 AM, Steve Loughran <<>>

On 5 Jul 2017, at 14:40, Vadim Semenov <<>>

Are you sure that you use S3A?
Because EMR says that they do not support S3A
> Amazon EMR does not currently support use of the Apache Hadoop S3A file system.

Oof. I figured they didn't offer technical support for S3A, but didn't know that there was
something saying EMR does not support use of S3A. My impression was that many people were
using it and it's the recommended S3 library in Hadoop 2.7+<>
from Hadoop's point of view.

We're using it rather than S3N because we use encrypted buckets, and I don't think S3N supports
picking up credentials from a machine role. Also, it was a bit distressing that it's unmaintained
and has open bugs.

We're S3A rather than EMRFS because we have a setup where we submit work to a cluster via
spark-submit run outside the cluster master node with --master yarn. When you do this, the
Hadoop configuration accessible to spark-submit overrides that of the EMR cluster itself.
If you use a configuration that uses EMRFS and any of the resources (like the JAR) you give
to spark-submit are on S3, spark-submit will instantiate the EMRFS FileSystem impl, which
is currently only available on the cluster, and fail. That said, we could work around this
by resetting the configuration in code.

or, if you are using the URL s3:// to refer to amazon EMRs, just edit your app config so that
fs.s3.impl=org.apache.hadoop.fs.s3a.S3AFileSystem  and use s3:// everywhere (use the fs.s3a.
prefix for configuring s3 though)

I think that the HEAD requests come from the `createBucketIfNotExists` in the AWS S3 library
that checks if the bucket exists every time you do a PUT request, i.e. creates a HEAD request.

You can disable that by setting `fs.s3.buckets.create.enabled` to `false`
Oh, interesting. We are definitely seeing a ton of HEAD requests, which might be that. It
looks like the `fs.s3.buckets.create.enabled` is an EMRFS option, though, not one common to
the Hadoop S3 FileSystem implementations. Does that sound right?

Yeah, I'd like to see the stack traces before blaming S3A and the ASF codebase

(Sorry, to be clear -- I'm not trying to blame S3A. I figured someone else might've hit this
and bet we had just misconfigured something or were doing this the wrong way.)

no worries,..if you are seeing problems, it's important to know where they are surfacing.

One thing I do know is that the shipping S3A client doesn't have any explicit handling of
503/retry events. I know that:

There is some retry logic in bits of the AWS SDK related to file upload: that may log and
retry, but in all the operations listing files, getting their details, etc: no resilience
to throttling.

If it is surfacing against s3a, there isn't anything which can immediately be done to fix
it, other than "spread your data around more buckets". Do attach the stack trace you get under though: I'm about half-way through the
resilience code (& fault injection needed to test it). The more where I can see problems
arise, the more confident I can be that those codepaths will be resilient.

Will do!

We did end up finding that some of our jobs were sharding data way too finely, ending up with
5-10k+ tiny Parquet shards per table. This happened when we unioned many Spark DataFrames
together without doing a repartition or coalesce afterwards. After throwing in a repartition
(to additionally balance the output shards) we haven't seen the error, again, but our graphs
of S3 HEAD requests are still rather alarmingly high.

treewalking can be expensive that way; the more dirs you have, the more things look around.

If you are using S3A, and Hadoop 2.8+, log the toString() value of the FS after your submission.
It'll give you a list of all the stats it collects, including details fo high level API calls
alongside low level HTTP requests:

View raw message