Cassandra CQL read/write from spark using Java - [Remoting] Remoting error: [Startup timed out]

[sonyjv]

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.