wuchong commented on issue #2346: URL: https://github.com/apache/fluss/issues/2346#issuecomment-3734865528
Hi @gnuhpc, Sorry, I wasn’t able to reproduce the error (in server logs) in my local environment (even after running for 10+ minutes). While reviewing your `ArrowWalRepro` code, I noticed that the `flushEvery` parameter isn’t actually taking effect, because the loop **waits for a synchronous response on every `put` call** ([see line 171](https://gist.github.com/gnuhpc/d40862863b5c401b58a9761b6301970f#file-arrowwalrepro-java-L171)). This effectively serializes all writes and blocks progress. When I changed that line to use `writer.upsert(row)` (asynchronous batching), the program completed successfully in about **16 seconds with no errors**. With the original synchronous approach, it didn’t finish even after 10 minutes (but also no errors in logs). Additionally, the stack trace in your logs references `fluss-cli-0.9-SNAPSHOT.jar:0.9-SNAPSHOT`. This is puzzling, **the `main` branch of Fluss doesn’t include a `fluss-cli` module**. Could it be possible that changes are contributing to the `IndexOutOfBoundsException`? I will try to reproduce again when I have another free time. -- 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]
