diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java index c76aee2f7..0779a1343 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java @@ -191,10 +191,11 @@ public class SeaweedOutputStream extends OutputStream { return; } - LOG.debug("close path: {}", path); + LOG.info("close: path={} totalPosition={} buffer.position()={}", path, position, buffer.position()); try { flushInternal(); threadExecutor.shutdown(); + LOG.info("close completed: path={} finalPosition={}", path, position); } finally { lastError = new IOException("Stream is closed!"); ByteBufferPool.release(buffer);