Destination S3-V2: Bug Fix: File xfer uses part size for part, not fi…

…le size
airbytehq · Jan 30, 2025 · 6197254 · 6197254
1 parent e2edfd7
commit 6197254
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...t-storage/src/main/kotlin/io/airbyte/cdk/load/write/object_storage/FilePartAccumulator.kt b/...t-storage/src/main/kotlin/io/airbyte/cdk/load/write/object_storage/FilePartAccumulator.kt
@@ -44,7 +44,7 @@ class FilePartAccumulator(
 
         while (true) {
             val bytePart =
-                ByteArray(ObjectStorageUploadConfiguration.DEFAULT_FILE_SIZE_BYTES.toInt())
+                ByteArray(ObjectStorageUploadConfiguration.DEFAULT_PART_SIZE_BYTES.toInt())
             val read = fileInputStream.read(bytePart)
 
             if (read == -1) {