пакет com.saprk.demo
import org.apache.spark.sql.SparkSession
object Hive {
def main (args: Array [String]){
val spark = SparkSession
.builder()
.master("local")
.appName("Spark SQL basic example")
.config("hive.metastore.warehouse.dir", "hdfs://user/hive/warehouse")
.enableHiveSupport()
.getOrCreate()
spark.sql("create database employee")
spark.sql("show databases").show()
}
}
Я пытаюсь создать базу данных в Hive с помощью spark и, отправляя ее на amazon emr, получаю исключение
Не удалось загрузить com.saprk.demo.Hive.java.lang.ClassNotFoundException: com.saprk.demo.Hive