divijvaidya commented on PR #14483:
URL: https://github.com/apache/kafka/pull/14483#issuecomment-1775107621
Adding here the reason @jeel2420 mentioned the cause of flaky test:
```
In getIndexFileFromRemoteCacheDir function we basically run below code to
get the files from the disk and checking if file with specific suffix is
present or not.
Files.walk(cache.cacheDir().toPath())
.filter(Files.isRegularFile(_))
.filter(path => path.getFileName.toString.endsWith(suffix))
.findAny()
Here in cacheDir after the remove call we can have files with .deleted
suffix and those files can be removed from cacheDir at any time. So if .deleted
suffix file got deleted in between when the above code is running which
basically traverse the directory structure we can get UncheckedIOException
which is not handled in the function.
```
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
