From 3895b2113a726171b3c9c04fe41b3cc93d6d14b5 Mon Sep 17 00:00:00 2001
From: tedyu <yuzhihong@gmail.com>
Date: Sun, 18 Oct 2015 02:12:56 -0700
Subject: [PATCH] [SPARK-11172] Close JsonParser/Generator in test
Author: tedyu <yuzhihong@gmail.com>
Closes #9157 from tedyu/master.
---
.../sql/execution/datasources/json/JsonSuite.scala | 14 ++++++++------
1 file 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
--
GitLab