ahmarsuhail commented on code in PR #7214:
URL: https://github.com/apache/hadoop/pull/7214#discussion_r1959501738
##########
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java:
##########
@@ -778,22 +775,39 @@ public void initialize(URI name, Configuration
originalConf)
longBytesOption(conf, ASYNC_DRAIN_THRESHOLD,
DEFAULT_ASYNC_DRAIN_THRESHOLD, 0),
inputPolicy);
- vectoredActiveRangeReads = intOption(conf,
- AWS_S3_VECTOR_ACTIVE_RANGE_READS,
DEFAULT_AWS_S3_VECTOR_ACTIVE_RANGE_READS, 1);
- vectoredIOContext = populateVectoredIOContext(conf);
scheme = (this.uri != null && this.uri.getScheme() != null) ?
this.uri.getScheme() : FS_S3A;
optimizedCopyFromLocal = conf.getBoolean(OPTIMIZED_COPY_FROM_LOCAL,
OPTIMIZED_COPY_FROM_LOCAL_DEFAULT);
LOG.debug("Using optimized copyFromLocal implementation: {}",
optimizedCopyFromLocal);
s3AccessGrantsEnabled = conf.getBoolean(AWS_S3_ACCESS_GRANTS_ENABLED,
false);
int rateLimitCapacity = intOption(conf, S3A_IO_RATE_LIMIT,
DEFAULT_S3A_IO_RATE_LIMIT, 0);
- // now create the store
+
+ // now create and initialize the store
store = createS3AStore(clientManager, rateLimitCapacity);
// the s3 client is created through the store, rather than
// directly through the client manager.
// this is to aid mocking.
- s3Client = store.getOrCreateS3Client();
+ s3Client = getStore().getOrCreateS3Client();
+
+ // get the input stream factory requirements.
+ final StreamFactoryRequirements factoryRequirements =
+ getStore().factoryRequirements();
+
+ // If the input stream can issue get requests outside spans,
+ // the auditor is forced to disable rejection of unaudited requests.
+ final EnumSet<AuditorFlags> flags = EnumSet.noneOf(AuditorFlags.class);
+ if (factoryRequirements.requires(ExpectUnauditedGetRequests)) {
+ flags.add(AuditorFlags.PermitOutOfBandOperations);
+ }
+ getAuditManager().setAuditFlags(flags);
+ // get the vector IO context from the factory.o
Review Comment:
nit: typo "factory.o"
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
