SparksFyz opened a new pull request, #3796:
URL: https://github.com/apache/celeborn/pull/3796
### What changes were proposed in this pull request?
Wait for asynchronous disk flushing to complete before checking the file
length in Flink `WordCountTest`.
This applies the same bounded `eventually` check already used by
`HybridShuffleWordCountTest`.
### Why are the changes needed?
`DiskFileInfo` records the logical file length before `LocalFlusher`
finishes writing the physical file.
The test may check the file too early and observe a temporary length of
zero, causing an intermittent failure.
### Does this PR resolve a correctness bug?
- [ ] Yes
### Does this PR introduce _any_ user-facing change?
- [ ] Yes
### How was this patch tested?
- Verified the change with `git diff --check`.
- The fix follows the existing handling in `HybridShuffleWordCountTest`.
--
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]
