gaborgsomogyi commented on code in PR #27026:
URL: https://github.com/apache/flink/pull/27026#discussion_r3302735832
##########
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/AbstractS3FileSystemFactory.java:
##########
@@ -245,4 +245,12 @@ protected FileSystem createFlinkFileSystem(
@Nullable
protected abstract S3AccessHelper
getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs);
+
+ /**
+ * Updates the Hadoop configuration with delegation token credentials
provider. Subclasses can
+ * override this method to use a different credentials provider (e.g., SDK
v2 only).
+ */
+ protected void
updateDelegationTokenConfig(org.apache.hadoop.conf.Configuration hadoopConfig) {
+ AbstractS3DelegationTokenReceiver.updateHadoopConfig(hadoopConfig);
+ }
Review Comment:
Ah ok, I was too quick. See that we have static + normal method so this is
fine
--
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]
