fresh-borzoni opened a new pull request, #147:
URL: https://github.com/apache/fluss-rust/pull/147
## Summary
Fixes critical bug where `flushes_in_progress` counter is never
decremented, causing batching to be permanently disabled after the first flush.
Closes #146
## The Bug
`begin_flush()` increments the counter but `await_flush_completion()`
never decrements it. This is a porting error from the Java implementation which
correctly decrements in a `finally` block.
## Impact
After the first `flush()` call:
- `flushes_in_progress` stays at 1 forever
- `flush_in_progress()` always returns `true`
- All batches become immediately sendable (no batching optimization)
## The Fix
Always decrement counter after flush completes (mimics Java `finally` block)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
