Hi,
I created an instance of LocalHiveContext and attempted to create a database.
However, it failed with message
"org.apache.spark.sql.execution.QueryExecutionException: FAILED: Execution
Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask.
java.lang.RuntimeException: Unable to instantiate
org.apache.hadoop.hive.metastore.HiveMetaStoreClient”.
My code is as follows. Similar code worked on spark-shell and also
bin/run-example org.apache.spark.examples.sql.hive.HiveFromSpark.
import org.apache.spark.{SparkContext, SparkConf}
import org.apache.spark.SparkContext._
import org.apache.spark.sql.hive.LocalHiveContext
val conf = new SparkConf(false).setMaster("local").setAppName("test data
exchange with Hive")
conf.set("spark.driver.host", "localhost")
val sc = new SparkContext(conf)
val hc = new LocalHiveContext(sc)
hc.hql(“create database if not exists testdb")
The exception was thrown out of the hql call. Did I miss any configuration?
Thanks,
Du
