Я создаю задание Spark SQL с сервером заданий Spark и использую HiveContext, следуя примеру ниже: https://github.com/spark-jobserver/spark-jobserver/blob/master/job-server-extras/src/spark.jobserver/HiveTestJob.scala
Мне удалось запустить сервер, но когда я запускаю свое приложение (мой класс Scala, расширяющий SparkSqlJob), я получаю в ответ следующее:
{
"status": "ERROR",
"result": "Invalid job type for this context"
}
Может ли кто-нибудь подсказать мне, что происходит не так, или предоставить подробную процедуру настройки сервера заданий для SparkSQL?
Код ниже:
import com.typesafe.config.{Config, ConfigFactory}
import org.apache.spark._
import org.apache.spark.sql.hive.HiveContext
import spark.jobserver.{SparkJobValid, SparkJobValidation, SparkHiveJob}
object newHiveRest extends SparkHiveJob {
def validate(hive: HiveContext, config: Config): SparkJobValidation = SparkJobValid
def runJob(hive: HiveContext, config: Config): Any = {
hive.sql(s"use default")
val maxRdd = hive.sql(s"select count(*) from 'default'.'passenger'")
maxRdd.count()
}
}