0

snappydata cli から jar ファイルを実行しようとしています。

最初に sparkSession と SnappyData セッションを作成したいだけです。

package io.test

import org.apache.spark.sql.{SnappySession, SparkSession}

object snappyTest {

  def main(args: Array[String]) {
  val spark: SparkSession = SparkSession
  .builder
  .appName("SparkApp")
  .master("local")
  .getOrCreate

 val snappy = new SnappySession(spark.sparkContext)
 }
}

sbt ファイルから:

name := "SnappyPoc"

version := "0.1"

scalaVersion := "2.11.8"

libraryDependencies += "io.snappydata" % "snappydata-cluster_2.11" % "1.0.0"

IDE でコードをデバッグしているときは正常に動作しますが、jar ファイルを作成して snappy で直接実行しようとすると、次のメッセージが表示されます。

"message": "Ask timed out on [Actor[akka://SnappyLeadJobServer/user/context-supervisor/snappyContext1508488669865777900#1900831413]] after [10000 ms]",
"errorClass": "akka.pattern.AskTimeoutException",

Spark Standalone 2.1.1、SnappyData 1.0.0 を使用しています。Spark インスタンスに依存関係を追加しました。

私たちを手伝ってくれますか ?。よろしくお願いします。

4

2 に答える 2