Когда я отправляю задание на сервер заданий Spark, я вижу, что контекст Spark создан.Однако в методе WebApi.getJobManagerForContext есть ошибка:
[2018-06-11 07: 05: 24,495] INFO ocalContextSupervisorActor [] [] - SparkContext 9f3d1f60-spark.jobserver.WordCountExample initialized {
"status": "ERROR", "result": {"message": "(Actor [akka: //JobServer/user/context-supervisor/9f3d1f60-spark.jobserver.WordCountExample#-1687191062], Actor [akka: // JobServer / пользователь / context-supervisor / global-result-actor # 1953406985]) (класса scala.Tuple2) "," errorClass ":" scala.MatchError "," stack ":" scala.MatchError: (Актер [akka: //JobServer/user/context-supervisor/9f3d1f60-spark.jobserver.WordCountExample#-1687191062], Актер [akka: // JobServer / пользователь / context-supervisor / global-result-actor # 1953406985]) (класса scala.Tuple2) в spark.jobserver.WebApi.spark $ jobserver $ WebApi $$ getJobManagerForContext (WebApi.scala: 728) в spark.jobserver.WebApi $$ anonfun $ jobRoutes $ 1 $$ anonfun $ применить $ 75 $$$ на себяприменить $ 76.apply (WebApi.scala: 640) в spark.jobserver.WebApi $$ anonfun $ jobRoutes $ 1 $$ anonfun $ применить $ 75 $$ anonfun $ apply $ 76.apply (WebApi.scala: 630) в spray.routing.ApplyConverterInstances $$ anon $ 17 $$ anonfun $ apply $ 6.apply (ApplyConverterInstances.scala: 60) в spray.routing.ApplyConverterInstances $$ anon $ 17 $$ anonfunприменить $ 6.apply (ApplyConverterInstances.scala: 59) на странице spray.routing.ConjunctionMagnet $$ anon $ 3 $$ anon $ 4 $$ anonfun $ счастливо $ 1 $$ anonfun $ применить $ 1.apply (Directive.scala: 38) на spray.routing.ConjunctionMagnet $$ anon $ 3 $$ anon $ 4 $$ anonfun $ happy $ 1 $$ anonfun $ apply $ 1.apply (Directive.scala: 37) в spray.routing.directives.BasicDirectives $$ anon $ 2.happly (BasicDirectives.scala:79) at spray.routing.Directive $$ anon $ 7 $$ anonfun $ happyly $ 4.apply (Directive.scala: 86) at spray.routing.Directive $$ anon $ 7 $$ anonfun $ happyly $ 4.apply (Directive.scala:86) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) at spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly$ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) вspray.routing.directives.BasicDirectives $$ anonfun $ mapRequestКонтекст $ 1 $$ anonfun $ apply $ 1.apply (BasicDirectives.scala: 30) в spray.routing.directives.BasicDirectives $$ anonfun $ mapRequestContext $ 1 $$ anonfun $ применить $ 1.apply (BasicDirectives.scala: 30) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) на странице spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92)at spray.routing.directives.BasicDirectives $$ anonfun $ mapRequestContext $ 1 $$ anonfun $ apply $ 1.apply (BasicDirectives.scala: 30)в spray.routing.directives.BasicDirectives $$ anonfun $ mapRequestContext $ 1 $$ anonfun $ apply $ 1.apply (BasicDirectives.scala: 30) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.RouteConcatenation $ RouteConcatenation $$ anonfun $$ тильда $ 1 $$anonfun $ apply $ 1.apply (RouteConcatenation.scala: 32) в spray.routing.RouteConcatenation $ RouteConcatenation $$ anonfun $$ tilde $ 1 $$ anonfun $ применять $ 1.apply (RouteConcatenation.scala: 31) в spray.routing.RequestContext $$ anonfun $ withRejectionHandling $ 1.applyOrElse (RequestContext.scala: 130) в scala.runtime.AbstractPartialFunction.apply (AbstractPartialFunction.scala: 36) в spray.routing.RequestContext $$ anon $ 1.handle (RequestContext.sck at 84).spray.UnregisteredActorRefBase. $ bang (UnregisteredActorRefBase.scala: 72) в spray.routing.RequestContext $$ anon $ 3.handle (RequestContext.scala: 102) в akka.spray.UnregisteredActorRefBase. $ bang (UnregisteredActorRefBase.scala: 72) на странице spray.routing.RequestContext.reject (RequestContext.scala: 202) на странице spray.routing.directives.RouteDirectives $$ anon $ 1.apply (RouteDirectives.scala: 35 at)routing.directives.RouteDirectives $$ anon $ 1.apply (RouteDirectives.scala: 34) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.directives.BasicDirectives $$ anon $ 3 $$ anonfun $ happyly $ 1.apply (BasicDirectives.scala: 92) в spray.routing.RouteConcatenation $ RouteConcatenation $$ anonfun $$ тильда $ 1 $$ anonfun $ применить $ 1.apply (RouteConcatenation.scala:32) at spray.routing.RouteConcatenation $ RouteConcatenation $$ anonfun $$ тильда $ 1 $$ anonfun $ apply $ 1.apply (RouteConcatenation.scala: 31) в spray.routing.RequestContext $$ anonfun $ withRejectionHandling $ 1.applyOrtel.se: 130) в scala.runtime.AbstractPartialFunction.apply (AbstractPartialFunction.scala: 36) в spray.routing.RequestContext $$ anon $ 1.handle (RequestContext.scala: 84) в akka.spray.UnregisteredActorRefBase. $ bang (UnregisteredActorRefBase.scala: 72) в spray.routing.RequestContext $$ anon $ 3.handle (RequestContext.scala: 102) в akka.spray.UnregisteredActorRefBase. $ bang ($ bang ($ bang)..scala: 72) в spray.routing.RequestContext.reject (RequestContext.scala: 202) в spray.routing.directives.RouteDirectives $$ anon $ 1.apply (RouteDirectives.scala: 35) в spray.routing.directives.RouteDirectives $$ anon $ 1.apply (RouteDirectives.scala: 34) "}