2016-02-18 4 views
0

Я запускаю запросы на кусты, используя Spark-SQL. Я сделал улей объект контекстаПодключение к улью с использованием Spark-SQL

val hiveContext = new org.apache.spark.sql.hive.HiveContext(sc); 

Тогда, когда я пытаюсь запустить команду:

hiveContext.sql("use db_name"); 

ИЛИ

hiveContext.hiveql("use db_name"); 

Это не работает. Это говорит database not found. Когда я пытаюсь запустить

val db = hiveContext.hiveql("show databases"); 
db.collect.foreach(println); 

Он ничего не печатает. Просто печатает [default].

Любая помощь будет оценена по достоинству.

+0

Вы настроили правильный 'metsastore' в' hive-default.xml'? и скопировал тот же файл в папку 'SPARK_HOME/conf'? – Sumit

+0

Я работаю в распределении cloudera. Должен ли я позаботиться об этом? –

+0

На какой платформе вы отправляете свои работы Spark? Автономный/Пряжа или Мезо или? – Sumit

ответ

0
hiveContext.sql("SELECT * FROM database.table") 
Смежные вопросы