ausführen von Hive-Abfragen von Spark

Ich versuche, diesen code ausführen, werden in der Funke-shell:

val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
sqlContext.sql("show tables")

Nach der Ausführung der zweiten Zeile, ich bin immer eine Ausnahme:

java.lang.NoSuchMethodError:
org.apache.hadoop.hive.ql.- Treiber.getResults(Ljava/util/ArrayList;)Z
bei org.apache.spark.sql.hive.HiveContext.runHive(HiveContext.scala:305)
bei org.apache.spark.sql.hive.HiveContext.runSqlHive(HiveContext.scala:272)
bei org.apache.spark.sql.hive.Ausführung.NativeCommand.sideEffectResult$lzycompute(NativeCommand.scala:35)
bei org.apache.spark.sql.hive.Ausführung.NativeCommand.sideEffectResult(NativeCommand.scala:35)
bei org.apache.spark.sql.hive.Ausführung.NativeCommand.execute(NativeCommand.scala:38)
bei org.apache.spark.sql.hive.HiveContext$QueryExecution.toRdd$lzycompute(HiveContext.scala:360)
bei org.apache.spark.sql.hive.HiveContext$QueryExecution.toRdd(HiveContext.scala:360)
bei org.apache.spark.sql.SchemaRDDLike$Klasse.$init$(SchemaRDDLike.scala:58)
bei org.apache.spark.sql.SchemaRDD.(SchemaRDD.scala:103)
bei org.apache.spark.sql.hive.HiveContext.sql(HiveContext.scala:98)
bei $iwC$$iwC$$iwC$$iwC.(:14) ...

Bitte helfen Sie mir, dieses Problem beheben.

InformationsquelleAutor facha | 2015-01-07
Schreibe einen Kommentar