-
- Downloads
[SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and example
## What changes were proposed in this pull request? This is a follow-up work of #15618. Close file source; For any newly created streaming context outside the withContext, explicitly close the context. ## How was this patch tested? Existing unit tests. Author: wm624@hotmail.com <wm624@hotmail.com> Closes #15818 from wangmiao1981/rtest.
Showing
- core/src/test/scala/org/apache/spark/util/MutableURLClassLoaderSuite.scala 14 additions, 0 deletions...la/org/apache/spark/util/MutableURLClassLoaderSuite.scala
- examples/src/main/scala/org/apache/spark/examples/LocalFileLR.scala 3 additions, 1 deletion...rc/main/scala/org/apache/spark/examples/LocalFileLR.scala
- external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala 2 additions, 0 deletions...che/spark/streaming/kafka010/DirectKafkaStreamSuite.scala
- external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala 2 additions, 0 deletions...apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala
- external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala 1 addition, 0 deletions...a/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala
- sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala 6 additions, 1 deletion...spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala
- streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala 1 addition, 0 deletions...st/scala/org/apache/spark/streaming/CheckpointSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/scheduler/JobGeneratorSuite.scala 1 addition, 0 deletions.../apache/spark/streaming/scheduler/JobGeneratorSuite.scala
Loading
Please register or sign in to comment