你好,
我為他工作他火花連接器和注意到一些奇怪的我沒能弄清真相。
對於查詢DataFrames我們使用數據源v2 API委托org.apache.spark.sql.catalyst.json JSON解析。CreateJacksonParser——(https://github.com/couchbase/couchbase-spark-connector/blob/master/src/main/scala/com/couchbase/spark/query/QueryPartitionReader.scala L56) . .這一切工作正常,在當地的IDE設置或當作業發送到當地引發分布式安裝。
但是當我運行它在磚的筆記本,我得到:
工作階段失敗而終止。引起的:NoSuchMethodError: org.apache.spark.sql.catalyst.json.CreateJacksonParser .string美元(Lcom / fasterxml /傑克遜/核心/ JsonFactory; Ljava / lang / String;) Lcom / fasterxml /傑克遜/核心/ JsonParser;在org.apache.spark.sql.CouchbaseJsonUtils。美元anonfun createParser 1美元(CouchbaseJsonUtils.scala: 41) org.apache.spark.sql.catalyst.json.JacksonParser anonfun解析1美元美元。(JacksonParser.scala: 490)美元org.apache.spark.util.Utils .tryWithResource (Utils.scala: 2952) org.apache.spark.sql.catalyst.json.JacksonParser.parse (JacksonParser.scala: 490) com.couchbase.spark.query.QueryPartitionReader anonfun行2美元美元。(QueryPartitionReader.scala: 54) scala.collection.TraversableLike。anonfun flatMap美元1美元(TraversableLike.scala: 293) scala.collection.mutable.ResizableArray.foreach (ResizableArray.scala: 62) scala.collection.mutable.ResizableArray.foreach美元(ResizableArray.scala: 55) scala.collection.mutable.ArrayBuffer.foreach (ArrayBuffer.scala: 49) scala.collection.TraversableLike.flatMap .... (TraversableLike.scala: 293)java.lang.Thread.run (Thread.java: 748)
知道為什麼造成的:NoSuchMethodError: org.apache.spark.sql.catalyst.json.CreateJacksonParser .string美元(Lcom / fasterxml /傑克遜/核心/ JsonFactory; Ljava / lang / String;) Lcom / fasterxml /傑克遜/核心/ JsonParser;在這個環境中是不可用的?
謝謝,
邁克爾