Skip to content

Native s3 FileSystem #5

Open
Samrat002 wants to merge 9 commits intomasterfrom
native-fs-s3
Open

Native s3 FileSystem #5
Samrat002 wants to merge 9 commits intomasterfrom
native-fs-s3

Conversation

@Samrat002
Copy link
Owner

@Samrat002 Samrat002 commented Nov 2, 2025

setup and testing details

  1. POC is tested with the minio setup in local
  2. Used wordCount to read from the minio bucket and write output to the minio output dir
  3. Used streaming mode and enabled checkpointing to the minio bucket

Callout :

  1. Very minimal Unit test for this patch. This patch is intended for poc purposes
  2. Only tested with the WordCount job and other custom jobs with minio. I am in progress to test the patch with an actual S3 bucket and a more genuine Flink application that reads from S3, writes to S3, with checkpointing on S3

Outcome

Able to verify read, write and checkpointing using the native-s3-filesystem

Jobmanager log: https://drive.google.com/file/d/1lfEJRn9F-r72YgU_uyyQFlEg2VAN_3qJ/view?usp=sharing

TaskManager log :
taskmanager-1.log

Screenshot 2025-11-03 at 1 19 35 AM Screenshot 2025-11-03 at 1 19 59 AM Screenshot 2025-11-03 at 1 20 43 AM Screenshot 2025-11-03 at 1 20 52 AM Screenshot 2025-11-03 at 1 21 10 AM Screenshot 2025-11-03 at 1 22 27 AM

}

public void copyFiles(
List<PathsCopyingFileSystem.CopyRequest> requests, ICloseableRegistry closeableRegistry)

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

You should use closeableRegistry to handle cancellations.

private final S3TransferManager transferManager;
private final int maxConcurrentCopies;

public NativeS3BulkCopyHelper(S3TransferManager transferManager, int maxConcurrentCopies) {

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think you should include the optional dependency of aws-crt

@Samrat002 Samrat002 force-pushed the native-fs-s3 branch 3 times, most recently from a556415 to bcdcf46 Compare November 8, 2025 17:28
@Samrat002 Samrat002 force-pushed the native-fs-s3 branch 2 times, most recently from 481b28d to 7afeca8 Compare December 7, 2025 07:29
@Samrat002 Samrat002 force-pushed the native-fs-s3 branch 2 times, most recently from 15dacc2 to 434aaeb Compare February 2, 2026 20:02
@Samrat002 Samrat002 force-pushed the native-fs-s3 branch 3 times, most recently from 7786f0e to 2a1de0a Compare February 18, 2026 13:42
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

Comments