q1984201234 2017-03-20 08:00 采纳率: 0%
浏览 1794
已结题

如何 使用akk-http 提供spark 服务?

大概代码如下
object SparkServer extends App with SparkServices {
implicit val system = ActorSystem("spark-akka-http")
implicit val materializer = ActorMaterializer()
implicit val executionContext = system.dispatcher
val bindingFuture = Http().bindAndHandle(route, "192.168.xx.xx", 8001)
}

SparkServices 基础代码如下
val sparkConf = new SparkConf().setMaster("local[8]")
val sparkSession = SparkSession.builder
.appName("SpanMsgServer")
.config(sparkConf)
.enableHiveSupport()
.getOrCreate()

......
使用 spark-submit 提交的时候 报错
com.typesafe.config.ConfigException$Missing: No configuration setting found for key akka.stream
google 一下 pom 里面添加 如下

reference.conf

错误依旧, 没法在resources 目录下面添加
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/stream-configuration.html 下面的akka.stream 配置文件
出现新错误
comes com.typesafe.config.ConfigException$Missing: No configuration setting found for key debug-logging
怎么解决? 求大神指导下

  • 写回答

1条回答 默认 最新

  • kxiaozhuk 2018-11-01 08:51
    关注

    在resources下面添加一个application.conf文件,把akka.stream的配置以key-value的方式添加进去

    评论

报告相同问题?

悬赏问题

  • ¥15 YoloV5 第三方库的版本对照问题
  • ¥15 请完成下列相关问题!
  • ¥15 drone 推送镜像时候 purge: true 推送完毕后没有删除对应的镜像,手动拷贝到服务器执行结果正确在样才能让指令自动执行成功删除对应镜像,如何解决?
  • ¥15 求daily translation(DT)偏差订正方法的代码
  • ¥15 js调用html页面需要隐藏某个按钮
  • ¥15 ads仿真结果在圆图上是怎么读数的
  • ¥20 Cotex M3的调试和程序执行方式是什么样的?
  • ¥20 java项目连接sqlserver时报ssl相关错误
  • ¥15 一道python难题3
  • ¥15 牛顿斯科特系数表表示