This is an automated email from the ASF dual-hosted git repository.
mbalassi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 15c4d88eb78 [FLINK-31834][Azure] Free up disk space before caching
add 839b3b9005c [FLINK-31839][filesystems] Fix flink-s3-fs-hadoop and
flink-s3-fs-presto plugin collision
No new revisions were added by this update.
Summary of changes:
.../security/security-delegation-token.md | 21 ++++++++-----
.../fs/s3/common/AbstractS3FileSystemFactory.java | 4 +--
...java => AbstractS3DelegationTokenProvider.java} | 10 ++-----
...java => AbstractS3DelegationTokenReceiver.java} | 12 +++-----
.../DynamicTemporaryAWSCredentialsProvider.java | 2 +-
... => AbstractS3DelegationTokenProviderTest.java} | 23 ++++++++++----
... => AbstractS3DelegationTokenReceiverTest.java} | 35 ++++++++++++++--------
...DynamicTemporaryAWSCredentialsProviderTest.java | 12 ++++++--
.../token/S3HadoopDelegationTokenProvider.java | 31 +++++++++++++++++++
.../token/S3HadoopDelegationTokenReceiver.java | 31 +++++++++++++++++++
...ink.core.security.token.DelegationTokenProvider | 2 +-
...ink.core.security.token.DelegationTokenReceiver | 2 +-
.../token/S3PrestoDelegationTokenProvider.java | 31 +++++++++++++++++++
.../token/S3PrestoDelegationTokenReceiver.java | 31 +++++++++++++++++++
...ink.core.security.token.DelegationTokenProvider | 2 +-
...ink.core.security.token.DelegationTokenReceiver | 2 +-
.../token/DefaultDelegationTokenManager.java | 26 ++++++++++++++--
.../token/DefaultDelegationTokenManagerTest.java | 24 +++++++++++++++
18 files changed, 248 insertions(+), 53 deletions(-)
rename
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/token/{S3DelegationTokenProvider.java
=> AbstractS3DelegationTokenProvider.java} (94%)
rename
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/token/{S3DelegationTokenReceiver.java
=> AbstractS3DelegationTokenReceiver.java} (91%)
rename
flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/token/{S3DelegationTokenProviderTest.java
=> AbstractS3DelegationTokenProviderTest.java} (78%)
rename
flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/token/{S3DelegationTokenReceiverTest.java
=> AbstractS3DelegationTokenReceiverTest.java} (75%)
create mode 100644
flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/token/S3HadoopDelegationTokenProvider.java
create mode 100644
flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/token/S3HadoopDelegationTokenReceiver.java
copy flink-filesystems/{flink-s3-fs-base =>
flink-s3-fs-hadoop}/src/main/resources/META-INF/services/org.apache.flink.core.security.token.DelegationTokenProvider
(92%)
copy flink-filesystems/{flink-s3-fs-base =>
flink-s3-fs-hadoop}/src/main/resources/META-INF/services/org.apache.flink.core.security.token.DelegationTokenReceiver
(92%)
create mode 100644
flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/token/S3PrestoDelegationTokenProvider.java
create mode 100644
flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/token/S3PrestoDelegationTokenReceiver.java
rename flink-filesystems/{flink-s3-fs-base =>
flink-s3-fs-presto}/src/main/resources/META-INF/services/org.apache.flink.core.security.token.DelegationTokenProvider
(92%)
rename flink-filesystems/{flink-s3-fs-base =>
flink-s3-fs-presto}/src/main/resources/META-INF/services/org.apache.flink.core.security.token.DelegationTokenReceiver
(92%)
