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 aaa8b76..0b2ba75 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(); }