-
- Downloads
[SPARK-14914][CORE] Fix Resource not closed after using, mostly for unit tests
## What changes were proposed in this pull request? Close `FileStreams`, `ZipFiles` etc to release the resources after using. Not closing the resources will cause IO Exception to be raised while deleting temp files. ## How was this patch tested? Existing tests Author: U-FAREAST\tl <tl@microsoft.com> Author: hyukjinkwon <gurwls223@gmail.com> Author: Tao LI <tl@microsoft.com> Closes #15618 from HyukjinKwon/SPARK-14914-1.
Showing
- core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala 9 additions, 4 deletions...in/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala
- core/src/test/scala/org/apache/spark/FileSuite.scala 9 additions, 4 deletionscore/src/test/scala/org/apache/spark/FileSuite.scala
- core/src/test/scala/org/apache/spark/deploy/RPackageUtilsSuite.scala 22 additions, 13 deletions...st/scala/org/apache/spark/deploy/RPackageUtilsSuite.scala
- core/src/test/scala/org/apache/spark/deploy/history/FsHistoryProviderSuite.scala 7 additions, 1 deletion.../apache/spark/deploy/history/FsHistoryProviderSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/EventLoggingListenerSuite.scala 15 additions, 11 deletions...rg/apache/spark/scheduler/EventLoggingListenerSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/TaskResultGetterSuite.scala 4 additions, 3 deletions...la/org/apache/spark/scheduler/TaskResultGetterSuite.scala
- mllib/src/test/scala/org/apache/spark/mllib/util/MLUtilsSuite.scala 10 additions, 6 deletions...test/scala/org/apache/spark/mllib/util/MLUtilsSuite.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java 1 addition, 0 deletions...rc/test/java/org/apache/spark/streaming/JavaAPISuite.java
- streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala 9 additions, 7 deletions...st/scala/org/apache/spark/streaming/CheckpointSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/MasterFailureTest.scala 1 addition, 0 deletions.../scala/org/apache/spark/streaming/MasterFailureTest.scala
- streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockTrackerSuite.scala 5 additions, 0 deletions...rg/apache/spark/streaming/ReceivedBlockTrackerSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/util/WriteAheadLogSuite.scala 1 addition, 0 deletions.../org/apache/spark/streaming/util/WriteAheadLogSuite.scala
Loading
Please register or sign in to comment