apache-spark - Spark 作业服务器的 Spark SQL 作业中的错误 "Invalid job type for this context"

Question

我使用 spark 作业服务器创建了一个 spark SQL 作业，并按照以下示例使用 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()
  }
}

Answer 1

对于 Spark SQL，您可以使用以下内容

https://github.com/spark-jobserver/spark-jobserver/blob/master/job-server-extras/src/spark.jobserver/SqlTestJob.scala