大概代码如下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
怎么解决? 求大神指导下
如何 使用akk-http 提供spark 服务?
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
1条回答 默认 最新
- kxiaozhuk 2018-11-01 08:51关注
在resources下面添加一个application.conf文件,把akka.stream的配置以key-value的方式添加进去
解决 无用评论 打赏 举报
悬赏问题
- ¥15 #MATLAB仿真#车辆换道路径规划
- ¥15 java 操作 elasticsearch 8.1 实现 索引的重建
- ¥15 数据可视化Python
- ¥15 要给毕业设计添加扫码登录的功能!!有偿
- ¥15 kafka 分区副本增加会导致消息丢失或者不可用吗?
- ¥15 微信公众号自制会员卡没有收款渠道啊
- ¥100 Jenkins自动化部署—悬赏100元
- ¥15 关于#python#的问题:求帮写python代码
- ¥20 MATLAB画图图形出现上下震荡的线条
- ¥15 关于#windows#的问题:怎么用WIN 11系统的电脑 克隆WIN NT3.51-4.0系统的硬盘