We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent be3a20b commit a65c9e6Copy full SHA for a65c9e6
1 file changed
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/fetch_failure/ShuffleReaderGetHooks.scala
@@ -86,6 +86,7 @@ class FileDeletionShuffleReaderGetHook(
86
.flatMap(_.listFiles().iterator).headOption
87
datafile match {
88
case Some(file) => {
89
+ println(s"deleted ${file.getAbsolutePath}")
90
file.delete()
91
}
92
case None => throw new RuntimeException("unexpected, there must be some data file")
0 commit comments