File tree Expand file tree Collapse file tree 11 files changed +60
-47
lines changed
src/main/scala/org/apache/spark
catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions
core/src/test/scala/org/apache/spark/sql/execution/datasources/json Expand file tree Collapse file tree 11 files changed +60
-47
lines changed Original file line number Diff line number Diff line change 224224 <groupId >org.scala-lang</groupId >
225225 <artifactId >scala-library</artifactId >
226226 </dependency >
227+ <dependency >
228+ <groupId >org.scala-lang</groupId >
229+ <artifactId >scala-reflect</artifactId >
230+ </dependency >
227231 <dependency >
228232 <groupId >org.json4s</groupId >
229233 <artifactId >json4s-jackson_${scala.binary.version}</artifactId >
Original file line number Diff line number Diff line change @@ -36,7 +36,7 @@ import org.apache.spark.util.Utils
3636 * (2) the Spark version of the client / server
3737 * (3) an optional message
3838 */
39- @ JsonInclude (Include .NON_NULL )
39+ @ JsonInclude (Include .NON_ABSENT )
4040@ JsonAutoDetect (getterVisibility = Visibility .ANY , setterVisibility = Visibility .ANY )
4141@ JsonPropertyOrder (alphabetic = true )
4242private [rest] abstract class SubmitRestProtocolMessage {
Original file line number Diff line number Diff line change @@ -41,7 +41,7 @@ import org.apache.spark.internal.Logging
4141 * There is no particular relationship between an operation scope and a stage or a job.
4242 * A scope may live inside one stage (e.g. map) or span across multiple jobs (e.g. take).
4343 */
44- @ JsonInclude (Include .NON_NULL )
44+ @ JsonInclude (Include .NON_ABSENT )
4545@ JsonPropertyOrder (Array (" id" , " name" , " parent" ))
4646private [spark] class RDDOperationScope (
4747 val name : String ,
Original file line number Diff line number Diff line change @@ -42,7 +42,7 @@ private[spark] object KVUtils extends Logging {
4242 private [spark] class KVStoreScalaSerializer extends KVStoreSerializer {
4343
4444 mapper.registerModule(DefaultScalaModule )
45- mapper.setSerializationInclusion(JsonInclude .Include .NON_NULL )
45+ mapper.setSerializationInclusion(JsonInclude .Include .NON_ABSENT )
4646
4747 }
4848
Original file line number Diff line number Diff line change @@ -49,7 +49,7 @@ private[v1] class JacksonMessageWriter extends MessageBodyWriter[Object]{
4949 }
5050 mapper.registerModule(com.fasterxml.jackson.module.scala.DefaultScalaModule )
5151 mapper.enable(SerializationFeature .INDENT_OUTPUT )
52- mapper.setSerializationInclusion(JsonInclude .Include .NON_NULL )
52+ mapper.setSerializationInclusion(JsonInclude .Include .NON_ABSENT )
5353 mapper.setDateFormat(JacksonMessageWriter .makeISODateFormat)
5454
5555 override def isWriteable (
Original file line number Diff line number Diff line change @@ -87,16 +87,16 @@ htrace-core-3.0.4.jar
8787httpclient-4.5.6.jar
8888httpcore-4.4.10.jar
8989ivy-2.4.0.jar
90- jackson-annotations-2.6.7 .jar
91- jackson-core-2.6.7 .jar
90+ jackson-annotations-2.9.8 .jar
91+ jackson-core-2.9.8 .jar
9292jackson-core-asl-1.9.13.jar
93- jackson-databind-2.6.7.1 .jar
94- jackson-dataformat-yaml-2.6.7 .jar
93+ jackson-databind-2.9.8 .jar
94+ jackson-dataformat-yaml-2.9.8 .jar
9595jackson-jaxrs-1.9.13.jar
9696jackson-mapper-asl-1.9.13.jar
97- jackson-module-jaxb-annotations-2.6.7 .jar
98- jackson-module-paranamer-2.7.9 .jar
99- jackson-module-scala_2.11-2.6.7.1 .jar
97+ jackson-module-jaxb-annotations-2.9.8 .jar
98+ jackson-module-paranamer-2.9.8 .jar
99+ jackson-module-scala_2.11-2.9.8 .jar
100100jackson-xc-1.9.13.jar
101101janino-3.0.9.jar
102102javassist-3.18.1-GA.jar
@@ -179,7 +179,7 @@ shapeless_2.11-2.3.2.jar
179179shims-0.7.45.jar
180180slf4j-api-1.7.16.jar
181181slf4j-log4j12-1.7.16.jar
182- snakeyaml-1.15 .jar
182+ snakeyaml-1.23 .jar
183183snappy-0.2.jar
184184snappy-java-1.1.7.3.jar
185185spire-macros_2.11-0.13.0.jar
Original file line number Diff line number Diff line change @@ -87,16 +87,16 @@ htrace-core-3.1.0-incubating.jar
8787httpclient-4.5.6.jar
8888httpcore-4.4.10.jar
8989ivy-2.4.0.jar
90- jackson-annotations-2.6.7 .jar
91- jackson-core-2.6.7 .jar
90+ jackson-annotations-2.9.8 .jar
91+ jackson-core-2.9.8 .jar
9292jackson-core-asl-1.9.13.jar
93- jackson-databind-2.6.7.1 .jar
94- jackson-dataformat-yaml-2.6.7 .jar
93+ jackson-databind-2.9.8 .jar
94+ jackson-dataformat-yaml-2.9.8 .jar
9595jackson-jaxrs-1.9.13.jar
9696jackson-mapper-asl-1.9.13.jar
97- jackson-module-jaxb-annotations-2.6.7 .jar
98- jackson-module-paranamer-2.7.9 .jar
99- jackson-module-scala_2.11-2.6.7.1 .jar
97+ jackson-module-jaxb-annotations-2.9.8 .jar
98+ jackson-module-paranamer-2.9.8 .jar
99+ jackson-module-scala_2.11-2.9.8 .jar
100100jackson-xc-1.9.13.jar
101101janino-3.0.9.jar
102102javassist-3.18.1-GA.jar
@@ -180,7 +180,7 @@ shapeless_2.11-2.3.2.jar
180180shims-0.7.45.jar
181181slf4j-api-1.7.16.jar
182182slf4j-log4j12-1.7.16.jar
183- snakeyaml-1.15 .jar
183+ snakeyaml-1.23 .jar
184184snappy-0.2.jar
185185snappy-java-1.1.7.3.jar
186186spire-macros_2.11-0.13.0.jar
Original file line number Diff line number Diff line change @@ -86,17 +86,17 @@ htrace-core4-4.1.0-incubating.jar
8686httpclient-4.5.6.jar
8787httpcore-4.4.10.jar
8888ivy-2.4.0.jar
89- jackson-annotations-2.6.7 .jar
90- jackson-core-2.6.7 .jar
89+ jackson-annotations-2.9.8 .jar
90+ jackson-core-2.9.8 .jar
9191jackson-core-asl-1.9.13.jar
92- jackson-databind-2.6.7.1 .jar
93- jackson-dataformat-yaml-2.6.7 .jar
92+ jackson-databind-2.9.8 .jar
93+ jackson-dataformat-yaml-2.9.8 .jar
9494jackson-jaxrs-base-2.7.8.jar
9595jackson-jaxrs-json-provider-2.7.8.jar
9696jackson-mapper-asl-1.9.13.jar
97- jackson-module-jaxb-annotations-2.6.7 .jar
98- jackson-module-paranamer-2.7.9 .jar
99- jackson-module-scala_2.11-2.6.7.1 .jar
97+ jackson-module-jaxb-annotations-2.9.8 .jar
98+ jackson-module-paranamer-2.9.8 .jar
99+ jackson-module-scala_2.11-2.9.8 .jar
100100janino-3.0.9.jar
101101javassist-3.18.1-GA.jar
102102javax.annotation-api-1.2.jar
@@ -199,7 +199,7 @@ shapeless_2.11-2.3.2.jar
199199shims-0.7.45.jar
200200slf4j-api-1.7.16.jar
201201slf4j-log4j12-1.7.16.jar
202- snakeyaml-1.15 .jar
202+ snakeyaml-1.23 .jar
203203snappy-0.2.jar
204204snappy-java-1.1.7.3.jar
205205spire-macros_2.11-0.13.0.jar
Original file line number Diff line number Diff line change 158158 <scala .version>2.11.12</scala .version>
159159 <scala .binary.version>2.11</scala .binary.version>
160160 <codehaus .jackson.version>1.9.13</codehaus .jackson.version>
161- <fasterxml .jackson.version>2.6.7</fasterxml .jackson.version>
162- <fasterxml .jackson.databind.version>2.6.7.1</fasterxml .jackson.databind.version>
161+ <fasterxml .jackson.version>2.9.8</fasterxml .jackson.version>
163162 <snappy .version>1.1.7.3</snappy .version>
164163 <netlib .java.version>1.1.2</netlib .java.version>
165164 <calcite .version>1.2.0-incubating</calcite .version>
629628 <dependency >
630629 <groupId >com.fasterxml.jackson.core</groupId >
631630 <artifactId >jackson-databind</artifactId >
632- <version >${fasterxml.jackson.databind. version} </version >
631+ <version >${fasterxml.jackson.version} </version >
633632 </dependency >
634633 <dependency >
635634 <groupId >com.fasterxml.jackson.core</groupId >
641640 <dependency >
642641 <groupId >com.fasterxml.jackson.module</groupId >
643642 <artifactId >jackson-module-scala_${scala.binary.version}</artifactId >
644- <version >${fasterxml.jackson.databind. version} </version >
643+ <version >${fasterxml.jackson.version} </version >
645644 <exclusions >
646645 <exclusion >
647646 <groupId >com.google.guava</groupId >
Original file line number Diff line number Diff line change @@ -244,6 +244,13 @@ class JsonExpressionsSuite extends SparkFunSuite with ExpressionEvalHelper with
244244 " 1234" )
245245 }
246246
247+ test(" some big value" ) {
248+ val value = " x" * 3000
249+ checkEvaluation(
250+ GetJsonObject (NonFoldableLiteral ((s """ {"big": " $value"} """ )),
251+ NonFoldableLiteral (" $.big" )), value)
252+ }
253+
247254 val jsonTupleQuery = Literal (" f1" ) ::
248255 Literal (" f2" ) ::
249256 Literal (" f3" ) ::
You can’t perform that action at this time.
0 commit comments