Skip to content

[FLINK-39111][filesystem] Alter NativeS3AccessHelper Interface to NativeS3ObjectOperations#27906

Open
Samrat002 wants to merge 1 commit intoapache:masterfrom
Samrat002:FLINK-39111
Open

[FLINK-39111][filesystem] Alter NativeS3AccessHelper Interface to NativeS3ObjectOperations#27906
Samrat002 wants to merge 1 commit intoapache:masterfrom
Samrat002:FLINK-39111

Conversation

@Samrat002
Copy link
Copy Markdown
Contributor

@Samrat002 Samrat002 commented Apr 8, 2026

What is the purpose of the change

This pull request renames NativeS3AccessHelper to NativeS3ObjectOperations in the Native S3 FileSystem module. The old name was carried over from the legacy S3 connector pattern, where a generic "helper" abstracted away differences between Hadoop and Presto implementations. Since the Native S3 FileSystem has no such constraint, the class deserves a name that reflects its actual responsibility: encapsulating low-level S3 object operations (multipart upload lifecycle, putObject, getObject, deleteObject, getObjectMetadata).

As noted in the #27187

Brief change log

  • Renamed NativeS3AccessHelper to NativeS3ObjectOperations (file, class, logger, constructors)
  • Updated all references in NativeS3FileSystem, NativeS3RecoverableWriter, NativeS3RecoverableFsDataOutputStream, NativeS3Committer
  • Updated README.md class reference

Verifying this change

Existing tests, such as NativeS3FileSystemFactoryTest and S3ClientProviderTest, already cover this change. All existing tests pass unchanged since the rename has no behavioural impact.

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): no
  • The public API, i.e., is any changed class annotated with @public(Evolving): no
  • The serializers: no
  • The runtime per-record code paths (performance sensitive): no
  • Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no
  • The S3 file system connector: yes (rename only, no behavioral change)

Documentation

  • Does this pull request introduce a new feature? no
  • If yes, how is the feature documented? not applicable

@Samrat002
Copy link
Copy Markdown
Contributor Author

@gaborgsomogyi / @Izeren PTAL

@flinkbot
Copy link
Copy Markdown
Collaborator

flinkbot commented Apr 8, 2026

CI report:

Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

@Samrat002
Copy link
Copy Markdown
Contributor Author

@flinkbot run azure

1 similar comment
@Samrat002
Copy link
Copy Markdown
Contributor Author

@flinkbot run azure

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants