0

我的要求是使用喷雾从请求 uri 创建其余的 json。我正在使用requestUri指令来获取基本 URL。当我通过 IDE 或通过我系统上的本地 spark-submit 运行它时，我得到了正确的输出。但是当我spark-submit在集群上完成时，我没有使用requestUri指令获取基本 url。我得到的 url 是部分的。因此，预期的输出也不正确。

获取网址的代码是

requestUri {
      uri =>
      val reqUri = s"$uri"//uri.toString()
        complete {
        println ("URI " + reqUri)
    }
}

build.sbt 看起来像这样

scalaVersion := "2.10.5"

libraryDependencies += "org.apache.spark" %% "spark-core" % "1.4.0"

resolvers ++= Seq(
  "Akka Repository" at "http://repo.akka.io/releases/")

resolvers ++= Seq("Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/",
  "Spray Repository"    at "http://repo.spray.io")


libraryDependencies +=
  "com.typesafe.akka" %% "akka-actor" % "2.3.0"


libraryDependencies ++= {
  val sprayVersion      = "1.3.1"
  Seq(
    "io.spray"          %% "spray-can"       % sprayVersion,
    "io.spray"          %% "spray-routing"   % sprayVersion,
    "io.spray"          %% "spray-json"      % sprayVersion

  )
}

请让我知道如何解决此问题。您的所有建议都很有价值。提前致谢。

4

0 回答 0