-
Notifications
You must be signed in to change notification settings - Fork 4.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Destination S3V2: Fix: File xfer uses part size for part, not file size #52662
Destination S3V2: Fix: File xfer uses part size for part, not file size #52662
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
@@ -44,7 +44,7 @@ class FilePartAccumulator( | |||
|
|||
while (true) { | |||
val bytePart = | |||
ByteArray(ObjectStorageUploadConfiguration.DEFAULT_FILE_SIZE_BYTES.toInt()) | |||
ByteArray(ObjectStorageUploadConfiguration.DEFAULT_PART_SIZE_BYTES.toInt()) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should this class be reading from the ObjectStorageUploadConfiguration
instead of referencing the constant directly?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes
6197254
to
19ef4c3
Compare
19ef4c3
to
b37d539
Compare
b37d539
to
bd76580
Compare
bd76580
to
9802a01
Compare
9802a01
to
bef31d1
Compare
@@ -6,7 +6,7 @@ plugins { | |||
airbyteBulkConnector { | |||
core = 'load' | |||
toolkits = ['load-s3', 'load-avro', 'load-aws'] | |||
cdk = '0.296' | |||
cdk = 'local' |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's repin the cdk after ya?
What
This probably fixes the oom issue on large files