Guest User

Untitled

a guest
Oct 20th, 2017
65
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.64 KB | None | 0 0
  1. package io.test
  2.  
  3. import org.apache.spark.sql.{SnappySession, SparkSession}
  4.  
  5. object snappyTest {
  6.  
  7. def main(args: Array[String]) {
  8. val spark: SparkSession = SparkSession
  9. .builder
  10. .appName("SparkApp")
  11. .master("local")
  12. .getOrCreate
  13.  
  14. val snappy = new SnappySession(spark.sparkContext)
  15. }
  16. }
  17.  
  18. name := "SnappyPoc"
  19.  
  20. version := "0.1"
  21.  
  22. scalaVersion := "2.11.8"
  23.  
  24. libraryDependencies += "io.snappydata" % "snappydata-cluster_2.11" % "1.0.0"
  25.  
  26. "message": "Ask timed out on [Actor[akka://SnappyLeadJobServer/user/context-supervisor/snappyContext1508488669865777900#1900831413]] after [10000 ms]",
  27. "errorClass": "akka.pattern.AskTimeoutException",
Add Comment
Please, Sign In to add comment