luoyuxia opened a new issue, #1621: URL: https://github.com/apache/fluss/issues/1621
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar. ### Motivation Although #954 already introduced timeout closableiterator to fast fail flink test if it get more times to collect records before it reach to the ci 60min timeout. But we still see the test stuck util ci 60min timeout. Here is just one example: https://github.com/apache/fluss/actions/runs/16648794360 ### Solution - Correct the timeout closableiterator. Currently, it won't be timeout, since flink closableiterator#hasNext() will always block utils records comes in streaming mode - Make all directly use of flink closableiterator.next to use the timeout collect method ### Anything else? _No response_ ### Willingness to contribute - [x] I'm willing to submit a PR! -- 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: issues-unsubscr...@fluss.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
