Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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)
- }
- }
- name := "SnappyPoc"
- version := "0.1"
- scalaVersion := "2.11.8"
- libraryDependencies += "io.snappydata" % "snappydata-cluster_2.11" % "1.0.0"
- "message": "Ask timed out on [Actor[akka://SnappyLeadJobServer/user/context-supervisor/snappyContext1508488669865777900#1900831413]] after [10000 ms]",
- "errorClass": "akka.pattern.AskTimeoutException",
Add Comment
Please, Sign In to add comment