Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created on
09-11-2017
09:18 AM
- last edited on
04-21-2026
06:45 AM
by
GrazittiAPI
Hi,
I switched to Spark 2.2 and latest version of Livy and now I am having problem with Hive.
scala> spark.sql("select * from bikeshare.trips")
res5: org.apache.spark.sql.DataFrame = [tripid: int, duration: int ... 9 more fields]
But the same gives me this error in Hue notebook (Spark2.2)
In Zeppelin
spark.sql("select * from bikeshare.trips")
org.apache.spark.sql.AnalysisException: Table or view not found: `bikeshare`.`trips`; line 1 pos 14;
In Hue
spark.sql("select * from bikshare.trips")
'Project [*] +- 'UnresolvedRelation `bikshare`.`trips` at org.apache.spark.sql.catalyst.analysis.package$AnalysisErrorAt.failAnalysis(package.scala:42) at
org.apache.spark.sql.catalyst.analysis.CheckAnalysis$$anonfun$checkAnalysis$1.apply(CheckAnalysis.scala:82) at
org.apache.spark.sql.catalyst.analysis.CheckAnalysis$$anonfun$checkAnalysis$1.apply(CheckAnalysis.scala:78) at
org.apache.spark.sql.catalyst.trees.TreeNode.foreachUp(TreeNode.scala:127) at org.apache.spark.sql.catalyst.trees.TreeNode$$anonfun$foreachUp$1.apply(TreeNode.scala:126) at
org.apache.spark.sql.catalyst.trees.TreeNode$$anonfun$foreachUp$1.apply(TreeNode.scala:126) at scala.collection.immutable.List.foreach(List.scala:381) at
org.apache.spark.sql.catalyst.trees.TreeNode.foreachUp(TreeNode.scala:126) at org.apache.spark.sql.catalyst.analysis.CheckAnalysis$class.checkAnalysis(CheckAnalysis.scala:78) at
org.apache.spark.sql.catalyst.analysis.Analyzer.checkAnalysis(Analyzer.scala:91) at org.apache.spark.sql.execution.QueryExecution.assertAnalyzed(QueryExecution.scala:52) at
org.apache.spark.sql.Dataset$.ofRows(Dataset.scala:66) at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:623) ... 47 elided
The spark.catalog shows empty table
spark.catalog.listTables.show +----+--------+-----------+---------+-----------+ |name|database|description|tableType|isTemporary| +----+--------+-----------+---------+-----------+ +----+--------+-----------+---------+-----------+
Listing databases in spark-shell displays all the databases but in Hue/Livy
spark.sql("show databases").show
+------------+
|databaseName|
+------------+
| default|
+------------+So of course the bikeshare doesn't exist from Livy
spark.sql("use bikshare")
org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException: Database 'bikshare' not found;Is there something I am missing here? It used to work in spark 1.6 wih sqlContext. It's like it couldn't load metastore metadata about all the warehouse directories etc.
Update: Hive Service for Spark 2 is enabled
Many thanks,
Maziyar
Created 09-11-2017 02:43 PM
I had to link hive-site.xml to spark conf dir manually!
export SPARK_HOME=/opt/cloudera/parcels/CDH/lib/spark
export SPARK_CONF_DIR=$SPARK_HOME/conf
sudo ln -s /etc/hive/conf/hive-site.xml $SPARK_CONF_DIR
I am not sure why this is not already in spark conf.
Problem has been solved.
Created 09-11-2017 02:43 PM
I had to link hive-site.xml to spark conf dir manually!
export SPARK_HOME=/opt/cloudera/parcels/CDH/lib/spark
export SPARK_CONF_DIR=$SPARK_HOME/conf
sudo ln -s /etc/hive/conf/hive-site.xml $SPARK_CONF_DIR
I am not sure why this is not already in spark conf.
Problem has been solved.
Created 10-20-2017 04:25 AM
I had the simillar issue, although symlinking did not help.
What I did was setting
livy.repl.enableHiveContext = true
in my livy.conf file. It is commented by default.