我使用Spark作业服务器创建了一个Spark SQL作业,并按照以下示例使用HiveContext:
https://github.com/spark-jobserver/spark-jobserver/blob/master/job-server-extras/src/spark.jobserver/HiveTestJob.scala
我能够启动服务器,但是当我运行我的应用程序(它是一个扩展了SparkSqlJob的Scala类)时,我收到以下响应:
{
"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()
}
}