Hi All,

I am using Apache Hadoop with Apache Flink and have a requirement of
passing confused deputy headers to all S3 requests being made from within
the framework. I was not able to find any config that allows users to pass
custom request headers that can be propagated as part of S3 api requests.

Is anyone aware of how to achieve this or is there any recommended way to
achieve this? If it's not supported yet would be a good candidate for a new
request ?

References:
Supported Configuration :
https://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/core-default.xml
Class which should add request headers as part of each request:
https://github.com/apache/hadoop/blob/trunk/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java


Thanks,
Saurav Kumar

Reply via email to