aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authortedyu <yuzhihong@gmail.com>2015-10-18 02:12:56 -0700
committerJosh Rosen <joshrosen@databricks.com>2015-10-18 02:12:56 -0700
commit3895b2113a726171b3c9c04fe41b3cc93d6d14b5 (patch)
treec93fb0b3206f49d1664a54aec5a5a6f5d8582bea /sql
parente2dfdbb2c0523517880138f214775f9a896f2271 (diff)
downloadspark-3895b2113a726171b3c9c04fe41b3cc93d6d14b5.tar.gz
spark-3895b2113a726171b3c9c04fe41b3cc93d6d14b5.tar.bz2
spark-3895b2113a726171b3c9c04fe41b3cc93d6d14b5.zip
[SPARK-11172] Close JsonParser/Generator in test
Author: tedyu <yuzhihong@gmail.com> Closes #9157 from tedyu/master.
Diffstat (limited to 'sql')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala14
1 files changed, 8 insertions, 6 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala
index b614e6c414..7540223bf2 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala
@@ -47,13 +47,15 @@ class JsonSuite extends QueryTest with SharedSQLContext with TestJsonData {
val factory = new JsonFactory()
def enforceCorrectType(value: Any, dataType: DataType): Any = {
val writer = new StringWriter()
- val generator = factory.createGenerator(writer)
- generator.writeObject(value)
- generator.flush()
+ Utils.tryWithResource(factory.createGenerator(writer)) { generator =>
+ generator.writeObject(value)
+ generator.flush()
+ }
- val parser = factory.createParser(writer.toString)
- parser.nextToken()
- JacksonParser.convertField(factory, parser, dataType)
+ Utils.tryWithResource(factory.createParser(writer.toString)) { parser =>
+ parser.nextToken()
+ JacksonParser.convertField(factory, parser, dataType)
+ }
}
val intNumber: Int = 2147483647