Support URI-aware operator injection for object storage
- Dominant language
- Rust
- Stars
- 197
- Forks
- 92
- Avg merge
- 1d 16h
- Merged PRs (30d)
- 91
Description
### Motivation
`FileIO` currently accepts object-store credentials as static properties. A long-lived `FileIO` cannot observe rotated temporary credentials without being rebuilt.
For example, an external process may atomically update a JSON file containing AK/SK/session token and expiration. The same `FileIO` should reload it when the cached credential expires. This is needed by the [Milvus external-table integration](https://github.com/milvus-io/milvus/issues/50632), where explicitly configured delegated authentication must also [fail closed](https://github.com/milvus-io/milvus-storage/issues/617).
### Proposal
Following iceberg-rust's [`CustomAwsCredentialLoader`](https://github.com/apache/iceberg-rust/blob/main/crates/storage/opendal/src/s3.rs), allow object-store builders used by `FileIO` to accept provider-specific reqsign credential providers.
- The provider returns the native credential and its expiration where supported. reqsign caches it and invokes the provider again when it becomes invalid.
- An explicitly configured provider replaces the default credential chain; refresh errors are returned without falling back to another identity.
- Existing property-based configuration remains unchanged. STS, OIDC, ARN, impersonation, and credential-broker implementations stay outside paimon-rust.
- Support S3 first, then use the same pattern for OSS, GCS, and Azure where OpenDAL / reqsign expose equivalent hooks.
Reloading credentials revoked before their declared expiration requires structured invalidation and retry support from OpenDAL / reqsign. Paimon should not implement this by matching cloud error strings.
Contributor guide
Research direction
Start with FileIO's object-store builders and existing property-based credential configuration, then inspect the OpenDAL/reqsign provider hooks described in the proposal. Done means S3 supports an explicit refreshable provider, uses its expiration, and returns refresh errors without falling back; add tests for provider refresh and fail-closed behavior.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- rust
- Domain
- authentication, cloud
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Quiet
- Clarity
- Mostly clear
- Newbie friendliness
- 45/100