add logging for RowConverter.close() (#115)

teragrep · Nov 13, 2024 · 39d6c62 · 39d6c62
1 parent 4d40630
commit 39d6c62
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/com/teragrep/pth_06/task/s3/RowConverter.java b/src/main/java/com/teragrep/pth_06/task/s3/RowConverter.java
@@ -371,6 +371,8 @@ private byte[] eventToSource() {
     }
 
     public void close() throws IOException {
+        final String logName = bucket + "/" + path;
+        LOGGER.info("S3FileHandler.close() on log: <{}> on offset <{}>", logName, currentOffset);
         if (inputStream != null) {
             inputStream.close();
         }