[client] Write sender I/O thread crashes with "Accounted size went negative" due to Arrow memory double-release in ArrowWriter

[LiebingYu]

Search before asking

• I searched in the issues and found nothing similar.

Fluss version

0.9.0 (latest release)

Please describe the bug 🐞

The Fluss write sender I/O thread crashes with java.lang.IllegalArgumentException: Accounted size went negative, originating from Apache Arrow's internal memory accounting layer. The error surfaces during server upgrade (though the exact correlation is unclear).

Full Stack Trace:

2026-03-16 18:26:55,245 [fluss-write-sender-thread-1] ERROR org.apache.fluss.client.write.Sender [] - Uncaught error in Fluss write sender I/O thread:
java.lang.IllegalArgumentException: Accounted size went negative.
    at org.apache.fluss.shaded.arrow.org.apache.arrow.util.Preconditions.checkArgument(Preconditions.java:136)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.memory.Accountant.releaseBytes(Accountant.java:219)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.memory.RootAllocator.releaseBytes(RootAllocator.java:29)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.memory.AllocationManager.release(AllocationManager.java:152)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.memory.BufferLedger.decrement(BufferLedger.java:157)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.memory.BufferLedger.release(BufferLedger.java:124)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.memory.BufferLedger.release(BufferLedger.java:104)
    at org.apache.fluss.shaded.arrow.org.apache.arrow.vector.ipc.message.ArrowRecordBatch.close(ArrowRecordBatch.java:243)
    at org.apache.fluss.row.arrow.ArrowWriter.serializeToOutputView(ArrowWriter.java:266)
    at org.apache.fluss.record.MemoryLogRecordsArrowBuilder.build(MemoryLogRecordsArrowBuilder.java:145)
    at org.apache.fluss.record.MemoryLogRecordsArrowBuilder.close(MemoryLogRecordsArrowBuilder.java:228)
    at org.apache.fluss.client.write.ArrowLogWriteBatch.close(ArrowLogWriteBatch.java:100)
    at org.apache.fluss.client.write.RecordAccumulator.drainBatchesForOneNode(RecordAccumulator.java:731)
    at org.apache.fluss.client.write.RecordAccumulator.drain(RecordAccumulator.java:286)
    at org.apache.fluss.client.write.Sender.sendWriteData(Sender.java:243)
    at org.apache.fluss.client.write.Sender.runOnce(Sender.java:194)
    at org.apache.fluss.client.write.Sender.run(Sender.java:164)

Solution

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!