From 39d6c62cccc12eb5d535707b9fc828f2423028c1 Mon Sep 17 00:00:00 2001
From: elliVM <126466762+elliVM@users.noreply.github.com>
Date: Wed, 13 Nov 2024 12:24:11 +0200
Subject: [PATCH] add logging for RowConverter.close() (#115)

---
 src/main/java/com/teragrep/pth_06/task/s3/RowConverter.java | 2 ++
 1 file changed, 2 insertions(+)

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
index aaa8b766..0b2ba75e 100644
--- 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();
         }