diff --git a/airbyte-cdk/java/airbyte-cdk/s3-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/s3/S3ConsumerFactory.kt b/airbyte-cdk/java/airbyte-cdk/s3-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/s3/S3ConsumerFactory.kt index a16a2a6baa7b..4ee61ac4daa0 100644 --- a/airbyte-cdk/java/airbyte-cdk/s3-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/s3/S3ConsumerFactory.kt +++ b/airbyte-cdk/java/airbyte-cdk/s3-destinations/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() }