From 1ca6d7f4419923a628a755b00caf942e20a3f4cb Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 23 Nov 2025 13:29:15 -0800 Subject: [PATCH] debug parquet footer writing --- .../main/java/seaweedfs/client/SeaweedOutputStream.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) 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 54a15bfba..437282744 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java @@ -100,7 +100,8 @@ public class SeaweedOutputStream extends OutputStream { public synchronized long getPos() { long currentPos = position + buffer.position(); if (path.contains("parquet")) { - LOG.info("[DEBUG-2024] 📍 getPos() called: flushedPosition={} bufferPosition={} returning={} totalBytesWritten={} writeCalls={}", + LOG.info( + "[DEBUG-2024] 📍 getPos() called: flushedPosition={} bufferPosition={} returning={} totalBytesWritten={} writeCalls={}", position, buffer.position(), currentPos, totalBytesWritten, writeCallCount); } return currentPos; @@ -173,12 +174,14 @@ public class SeaweedOutputStream extends OutputStream { // Log significant writes AND writes near the end (potential footer) if (path.contains("parquet")) { if (length >= 20) { - LOG.info("[DEBUG-2024] ✍️ write({} bytes): totalSoFar={} writeCalls={} position={} bufferPos={}, file={}", + LOG.info( + "[DEBUG-2024] ✍️ write({} bytes): totalSoFar={} writeCalls={} position={} bufferPos={}, file={}", length, totalBytesWritten, writeCallCount, position, buffer.position(), path.substring(path.lastIndexOf('/') + 1)); } else if (writeCallCount >= 220) { // Log all small writes after call 220 (likely footer writes) - LOG.info("[DEBUG-2024] ✍️ write({} bytes): totalSoFar={} writeCalls={} position={} bufferPos={} [FOOTER?], file={}", + LOG.info( + "[DEBUG-2024] ✍️ write({} bytes): totalSoFar={} writeCalls={} position={} bufferPos={} [FOOTER?], file={}", length, totalBytesWritten, writeCallCount, position, buffer.position(), path.substring(path.lastIndexOf('/') + 1)); }