From 2e903a2c4fcbdfc80d00c425f375cf684ae910d5 Mon Sep 17 00:00:00 2001 From: Gisli Magnusson Date: Wed, 11 Dec 2024 03:23:48 +0000 Subject: [PATCH] Fix excessive logging for S3 stream skipping. --- .../main/java/org/gorpipe/s3/driver/AbortingInputStream.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/drivers/src/main/java/org/gorpipe/s3/driver/AbortingInputStream.java b/drivers/src/main/java/org/gorpipe/s3/driver/AbortingInputStream.java index 48764af0..380e4744 100644 --- a/drivers/src/main/java/org/gorpipe/s3/driver/AbortingInputStream.java +++ b/drivers/src/main/java/org/gorpipe/s3/driver/AbortingInputStream.java @@ -74,10 +74,10 @@ public void close() throws IOException { if (missingBytes < SKIP_BYTES_THRESHOLD) { // If we are close to the end, skip the rest (to avoid aborting) long skipped = s3is.skip(missingBytes); - logger.warn("S3 stream, not all bytes read, skipping {} ({}) bytes out of {} bytes.", skipped, missingBytes, maxBytes); + logger.debug("S3 stream, not all bytes read, skipping {} ({}) bytes out of {} bytes.", skipped, missingBytes, maxBytes); s3is.close(); } else { - logger.warn("S3 stream, not all bytes read, aborting S3 input stream. {} bytes not read, of {} bytes.", missingBytes, maxBytes); + logger.debug("S3 stream, not all bytes read, aborting S3 input stream. {} bytes not read, of {} bytes.", missingBytes, maxBytes); s3is.abort(); } } else {