2017-02-25 10 views
0

私はSparkSqlを使用してハイブテーブルにアクセスするための簡単なコードを記述することを試みた:Spark-Hiveエラー、どうすれば解決できますか?

SparkSession spark = SparkSession.builder() 
           .appName("Java Spark Hive Example") 
           .master("local[*]") 
           .config("hive.metastore.uris", "thrift://localhost:9083") 
           .enableHiveSupport() 
           .getOrCreate(); 

try{ 
    Dataset<Row> df = spark.sql("select survey_response_value from health"); 
    df.show(); 
} catch (Exception AnalysisException) { 
    System.out.print("\nTable is not found\n"); 
} 

私は私のシステムで、この特定のプログラムを何度も走ったし、それがうまく動作していました。しかし、突然それは動作を停止し、エラーを出すようになりました。
エラーとトレースの完全な一覧を示します。
https://justpaste.it/13w2r
私はIntelliJを使用しています。

私は依存関係やコードに関して何もしていません。だから私はコードが動作しないものを理解していない。そして私はそれをどのように取り除くことができますか?親切に、助けてください。ここで が問題である:

17:22:50.442 [main] INFO org.apache.spark.SparkContext - Created broadcast 0 from show at hivespark.java:29 
Exception in thread "main" java.lang.ExceptionInInitializerError 
    at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:132) 
    at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:113) 
    at org.apache.spark.sql.execution.SparkPlan.getByteArrayRdd(SparkPlan.scala:225) 
    at org.apache.spark.sql.execution.SparkPlan.executeTake(SparkPlan.scala:308) 
    at org.apache.spark.sql.execution.CollectLimitExec.executeCollect(limit.scala:38) 
    at org.apache.spark.sql.Dataset$$anonfun$org$apache$spark$sql$Dataset$$execute$1$1.apply(Dataset.scala:2371) 
    at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:57) 
    at org.apache.spark.sql.Dataset.withNewExecutionId(Dataset.scala:2765) 
    at org.apache.spark.sql.Dataset.org$apache$spark$sql$Dataset$$execute$1(Dataset.scala:2370) 
    at org.apache.spark.sql.Dataset.org$apache$spark$sql$Dataset$$collect(Dataset.scala:2377) 
    at org.apache.spark.sql.Dataset$$anonfun$head$1.apply(Dataset.scala:2113) 
    at org.apache.spark.sql.Dataset$$anonfun$head$1.apply(Dataset.scala:2112) 
    at org.apache.spark.sql.Dataset.withTypedCallback(Dataset.scala:2795) 
    at org.apache.spark.sql.Dataset.head(Dataset.scala:2112) 
    at org.apache.spark.sql.Dataset.take(Dataset.scala:2327) 
    at org.apache.spark.sql.Dataset.showString(Dataset.scala:248) 
    at org.apache.spark.sql.Dataset.show(Dataset.scala:636) 
    at org.apache.spark.sql.Dataset.show(Dataset.scala:595) 
    at org.apache.spark.sql.Dataset.show(Dataset.scala:604) 
    at sparky.hivespark.main(hivespark.java:29) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:498) 
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147) 
Caused by: com.fasterxml.jackson.databind.JsonMappingException: Jackson version is too old 2.5.1 
    at com.fasterxml.jackson.module.scala.JacksonModule$class.setupModule(JacksonModule.scala:56) 
    at com.fasterxml.jackson.module.scala.DefaultScalaModule.setupModule(DefaultScalaModule.scala:19) 
    at com.fasterxml.jackson.databind.ObjectMapper.registerModule(ObjectMapper.java:651) 
    at org.apache.spark.rdd.RDDOperationScope$.<init>(RDDOperationScope.scala:82) 
    at org.apache.spark.rdd.RDDOperationScope$.<clinit>(RDDOperationScope.scala) 
    ... 25 more 
17:22:50.612 [Thread-2] INFO org.apache.spark.SparkContext - Invoking stop() from shutdown hook 
+0

をもらえ使用している場合、スコープを持つビルドファイルを置く、具体的には高速-xml依存 – FaigB

答えて

1

あなたはSBTを使用している場合は、その後追加....

をここで私はあなたにも2.5

の上、ご使用の環境での互換性のある任意のバージョンに言及することができ2.8.xを述べました
// https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core 
libraryDependencies += "com.fasterxml.jackson.core" % "jackson-core" % "2.8.7" 

// https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-databind 
libraryDependencies += "com.fasterxml.jackson.core" % "jackson-databind" % "2.8.7" 

あなたはヨーヨーの達人

<dependency> 
    <groupId>com.fasterxml.jackson.core</groupId> 
    <artifactId>jackson-core</artifactId> 
    <version>2.8.7</version> 
</dependency> 



<dependency> 
    <groupId>com.fasterxml.jackson.core</groupId> 
    <artifactId>jackson-databind</artifactId> 
    <version>2.8.7</version> 
</dependency> 
+0

あなたはこれの後に直面している何か他にありますか?応答して。 –

関連する問題