spark读取elasticsearch的时候,出错了,报错
com.fasterxml.jackson.databind.JsonMappingException: Incompatible Jackson version: 2.9.6
Exception in thread "main" java.lang.ExceptionInInitializerError at org.apache.spark.rdd.RDD.withScope(RDD.scala:362) at org.apache.spark.rdd.RDD.map(RDD.scala:369) at org.apache.spark.rdd.PairRDDFunctions.values(PairRDDFunctions.scala:1163) at Test$.main(Test.scala:14) at Test.main(Test.scala) Caused by: com.fasterxml.jackson.databind.JsonMappingException: Incompatible Jackson version: 2.9.6 at com.fasterxml.jackson.module.scala.JacksonModule$class.setupModule(JacksonModule.scala:64) at com.fasterxml.jackson.module.scala.DefaultScalaModule.setupModule(DefaultScalaModule.scala:19) at com.fasterxml.jackson.databind.ObjectMapper.registerModule(ObjectMapper.java:751) at org.apache.spark.rdd.RDDOperationScope$.<init>(RDDOperationScope.scala:82) at org.apache.spark.rdd.RDDOperationScope$.<clinit>(RDDOperationScope.scala) ... 5 more
因为我的pom.xml配置是spark2.0版本的,因为我的spark2.0版本依赖Jackson版本是2.6+的
所以我们只需要将Jackson2.6版本的引入即可,
<dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.6.6</version> </dependency>
如果还有错,那么可能是其他包引入了jackson的高版本,在其中将jackson的自动引入剔除即可,
<dependency> <groupId> org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>1.1.1</version> <exclusions> <exclusion> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>*</artifactId> </exclusion> </exclusions> </dependency>