q1984201234 2017-03-27 03:20 采纳率: 0%
浏览 2358

使用akka+http 提供spark 服务问题

使用 akka-http to 提供 http 服务 大致代码如下:

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

按照网上提示pom 加入


reference.conf

错误没怎么改变,修改 application.conf 添加如下http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/stream-configuration.html配置到 application.conf :

出现了com.typesafe.config.ConfigException$Missing: No configuration setting found for key debug-logging  怎么解决啊
  • 写回答

2条回答 默认 最新

  • threenewbee 2017-03-27 15:42
    关注
    评论

报告相同问题?

悬赏问题

  • ¥15 如何用Labview在myRIO上做LCD显示?(语言-开发语言)
  • ¥15 Vue3地图和异步函数使用
  • ¥15 C++ yoloV5改写遇到的问题
  • ¥20 win11修改中文用户名路径
  • ¥15 win2012磁盘空间不足,c盘正常,d盘无法写入
  • ¥15 用土力学知识进行土坡稳定性分析与挡土墙设计
  • ¥70 PlayWright在Java上连接CDP关联本地Chrome启动失败,貌似是Windows端口转发问题
  • ¥15 帮我写一个c++工程
  • ¥30 Eclipse官网打不开,官网首页进不去,显示无法访问此页面,求解决方法
  • ¥15 关于smbclient 库的使用