spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sonyjv <sonyjvech...@yahoo.com>
Subject Cassandra CQL read/write from spark using Java - [Remoting] Remoting error: [Startup timed out]
Date Thu, 20 Mar 2014 09:17:12 GMT
Hi,

In standalone mode I am trying to perform some Cassandra CQL read/write
operations. Following is my Maven dependencies.

		<dependency> 
			<groupId>org.apache.spark</groupId>
			<artifactId>spark-core_2.10</artifactId>
			<version>0.9.0-incubating</version>
		</dependency>
		<dependency>
			<groupId>org.apache.hadoop</groupId>
			<artifactId>hadoop-client</artifactId>
			<version>2.0.0-cdh4.5.0</version>
		</dependency>
		<dependency>
			<groupId>org.apache.cassandra</groupId>
			<artifactId>cassandra-all</artifactId>
			<version>2.0.6</version>
		</dependency>

While initiating JavaSparkContext I am getting the following error. 

Exception in thread "main" java.util.concurrent.TimeoutException: Futures
timed out after [10000 milliseconds]
	at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
	at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
	at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
	at scala.concurrent.Await$.result(package.scala:107)
	at akka.remote.Remoting.start(Remoting.scala:173)
	at
akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184)
	at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:579)
	at akka.actor.ActorSystemImpl._start(ActorSystem.scala:577)
	at akka.actor.ActorSystemImpl.start(ActorSystem.scala:588)
	at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
	at akka.actor.ActorSystem$.apply(ActorSystem.scala:104)
	at org.apache.spark.util.AkkaUtils$.createActorSystem(AkkaUtils.scala:96)
	at org.apache.spark.SparkEnv$.create(SparkEnv.scala:126)
	at org.apache.spark.SparkContext.<init>(SparkContext.scala:139)
	at
org.apache.spark.api.java.JavaSparkContext.<init>(JavaSparkContext.scala:47)
	at com.sample.spark.NewCassandraTest.main(NewCassandraTest.java:66)
[ERROR] [03/20/2014 14:34:50.429] [main] [Remoting] Remoting error: [Startup
timed out] [
akka.remote.RemoteTransportException: Startup timed out
	at
akka.remote.Remoting.akka$remote$Remoting$$notifyError(Remoting.scala:129)
	at akka.remote.Remoting.start(Remoting.scala:191)
	at
akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184)
	at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:579)
	at akka.actor.ActorSystemImpl._start(ActorSystem.scala:577)
	at akka.actor.ActorSystemImpl.start(ActorSystem.scala:588)
	at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
	at akka.actor.ActorSystem$.apply(ActorSystem.scala:104)
	at org.apache.spark.util.AkkaUtils$.createActorSystem(AkkaUtils.scala:96)
	at org.apache.spark.SparkEnv$.create(SparkEnv.scala:126)
	at org.apache.spark.SparkContext.<init>(SparkContext.scala:139)
	at
org.apache.spark.api.java.JavaSparkContext.<init>(JavaSparkContext.scala:47)
	at com.sample.spark.NewCassandraTest.main(NewCassandraTest.java:66)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
	at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
	at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
	at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
	at scala.concurrent.Await$.result(package.scala:107)
	at akka.remote.Remoting.start(Remoting.scala:173)
	... 11 more
]

I am clueless at the moment. Could you please let me know the issue. 

Thanks,
Sony 



--
View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Cassandra-CQL-read-write-from-spark-using-Java-Remoting-Remoting-error-Startup-timed-out-tp2925.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.

Mime
View raw message