fresh-borzoni opened a new pull request, #2989:
URL: https://github.com/apache/fluss/pull/2989
## Summary
closes #2661
Fix verified end-to-end against RustFS.
Before fix:
```
SecurityTokenException: Failed to get file access security token: Region
is not set.
-> NoAwsCredentialsException: Dynamic session credentials for Fluss: No
AWS Credentials
-> Flink job FAILED
```
After fix:
```
S3DelegationTokenProvider - Obtaining session credentials via AssumeRole
with access key: rustfsadmin, role: arn:xxx:xxx:xxx:xxxx
S3DelegationTokenProvider - Session credentials obtained successfully with
access key: I4MVXCHH4OV01YLLA9MC
S3DelegationTokenReceiver - Session credentials updated successfully
-> Flink job RUNNING
```
Config required for RustFS users:
```
s3.region: us-east-1
s3.assumed.role.arn: arn:xxx:xxx:xxx:xxxx
s3.assumed.role.sts.endpoint: http://rustfs:9000
```
Backward compatibility:
- Without s3.assumed.role.arn, falls back to GetSessionToken (existing AWS
behavior)
- Zero breaking changes for existing users
--
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]