diff options
author | tedyu <yuzhihong@gmail.com> | 2015-10-18 02:12:56 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2015-10-18 02:12:56 -0700 |
commit | 3895b2113a726171b3c9c04fe41b3cc93d6d14b5 (patch) | |
tree | c93fb0b3206f49d1664a54aec5a5a6f5d8582bea | |
parent | e2dfdbb2c0523517880138f214775f9a896f2271 (diff) | |
download | spark-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.
-rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala | 14 |
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 |