Spark 3.5: Fix flaky test due to deleting temp directory failure#10811
Conversation
|
This PR didn't fix but exposed more underlying errors from https://github.com/apache/iceberg/actions/runs/10156307633/job/28084490263?pr=10811 |
|
@Fokko @dramaticlly PTAL. This PR now proactively deletes temporary directory catching exceptions until it's cleaned up. |
|
cc @nastra please help review |
| assertThat(snapshotBeforeFailingWrite).isEqualTo(snapshotAfterFailingWrite); | ||
| assertThat(resultBeforeFailingWrite).isEqualTo(resultAfterFailingWrite); | ||
|
|
||
| while (location.exists()) { |
There was a problem hiding this comment.
this seems like a workaround. https://stackoverflow.com/questions/56290320/junit-cannot-delete-tempdir-with-file-created-by-spark-structured-streaming indicates that the issue might be due to a resource not being closed, so maybe we should investigate what the actual root cause of this issue is
Fokko
left a comment
There was a problem hiding this comment.
I'm seeing this one quite often. I would suggest merging this and creating an issue to track the underlying issue
fixes #10480
fixes #10569