Create table error from Hive in spark-assembly-1.0.2.jar

2014-10-26 Thread Jacob Chacko - Catalyst Consulting
Hi All We are trying to create a table in Hive from spark-assembly-1.0.2.jar file. CREATE TABLE IF NOT EXISTS src (key INT, value STRING) JavaSparkContext sc = CC2SparkManager.sharedInstance().getSparkContext(); JavaHiveContext sqlContext = new JavaHiveContext(sc); sqlContext.sql("CREATE

akka.remote.transport.netty.NettyTransport

2014-10-07 Thread Jacob Chacko - Catalyst Consulting
Hi All I have one master and one worker on AWS (amazon web service) and am running spark map reduce code provided on the link https://spark.apache.org/examples.html We are using Spark version 1.0.2 Word Count val file = spark.textFile("hdfs://...") val counts = file.flatMap(line => line.split("