Log file copy info

airbytehq · Oct 25, 2024 · d8a3bb0 · d8a3bb0
1 parent 367e2f0
commit d8a3bb0
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...tinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/s3/S3ConsumerFactory.kt b/...tinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/s3/S3ConsumerFactory.kt
@@ -307,6 +307,7 @@ class S3ConsumerFactory {
             val dataFile = File(absolutePath)
             val fileSize = dataFile.length()
             val startTimeMs = System.currentTimeMillis()
+            LOGGER.info { "Writing file: ${dataFile.name}" }
             storageOps.loadDataIntoBucket(
                 fullObjectKey = fullObjectKey,
                 fileName = dataFile.name,
@@ -318,6 +319,7 @@ class S3ConsumerFactory {
             LOGGER.info {
                 "wrote ${FileUtils.byteCountToDisplaySize(fileSize)} file in $elapsedTimeSeconds s, for a speed of ${decimalFormat.format(speedMBps)} MBps"
             }
+            LOGGER.info { "Deleting file: ${dataFile.name}" }
             dataFile.delete()
         }