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 インスタンスに依存関係を追加しました。
私たちを手伝ってくれますか ?。よろしくお願いします。