do not account for pending bytes when auto-flushing bytes is disabled

Author: jerrinot

core/src/main/java/io/questdb/client/cutlass/qwp/client/QwpWebSocketSender.java

@@ -1298,9 +1298,13 @@ private void sealAndSwapBuffer() {
      */
     private void sendRow() {
         ensureConnected();
-        long bytesBefore = currentTableBuffer.getBufferedBytes();
-        currentTableBuffer.nextRow();
-        pendingBytes += currentTableBuffer.getBufferedBytes() - bytesBefore;
+        if (autoFlushBytes > 0) {
+            long bytesBefore = currentTableBuffer.getBufferedBytes();
+            currentTableBuffer.nextRow();
+            pendingBytes += currentTableBuffer.getBufferedBytes() - bytesBefore;
+        } else {
+            currentTableBuffer.nextRow();
+        }
 
         // Both modes: accumulate rows, don't encode yet
         if (pendingRowCount == 0) {

core/src/test/java/io/questdb/client/test/cutlass/line/tcp/v4/QwpAllocationTestClient.java

@@ -209,7 +209,7 @@ private static Sender createSender(
                         .address(host)
                         .port(port);
                 if (batchSize > 0) wsBuilder.autoFlushRows(batchSize);
-                if (flushBytes > 0) wsBuilder.autoFlushBytes(flushBytes);
+                if (flushBytes >= 0) wsBuilder.autoFlushBytes(flushBytes);
                 if (flushIntervalMs > 0) wsBuilder.autoFlushIntervalMillis((int) flushIntervalMs);
                 if (inFlightWindow > 0) wsBuilder.inFlightWindowSize(inFlightWindow);
                 return wsBuilder.build();