It successfully writes some data and fails afterwards, like the host or connection goes down. Weird.
Maybe you should post this question on the Spark-Cassandra connector group: https://groups.google.com/a/lists.datastax.com/forum/#!forum/spark-connector-user -kr, Gerard. On Sun, May 10, 2015 at 12:23 PM, Sergio Jiménez Barrio < drarse.a...@gmail.com> wrote: > This is: > > 15/05/10 12:20:08 INFO TableWriter: Wrote 2 rows to ataques.attacks in > 0,016 s. > 15/05/10 12:20:08 INFO LocalNodeFirstLoadBalancingPolicy: Suspected host > 127.0.0.1 (datacenter1) > 15/05/10 12:20:08 ERROR Session: Error creating pool to /127.0.0.1:9042 > com.datastax.driver.core.ConnectionException: [/127.0.0.1:9042] > Unexpected error during transport initialization > (com.datastax.driver.core.TransportException: [/127.0.0.1:9042] Error > writing: Closed channel) > at > com.datastax.driver.core.Connection.initializeTransport(Connection.java:186) > at com.datastax.driver.core.Connection.<init>(Connection.java:116) > at > com.datastax.driver.core.PooledConnection.<init>(PooledConnection.java:32) > at > com.datastax.driver.core.Connection$Factory.open(Connection.java:586) > at > com.datastax.driver.core.DynamicConnectionPool.<init>(DynamicConnectionPool.java:74) > at > com.datastax.driver.core.HostConnectionPool.newInstance(HostConnectionPool.java:33) > at > com.datastax.driver.core.SessionManager$2.call(SessionManager.java:231) > at > com.datastax.driver.core.SessionManager$2.call(SessionManager.java:224) > at java.util.concurrent.FutureTask.run(FutureTask.java:262) > at > com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:293) > at > com.google.common.util.concurrent.AbstractListeningExecutorService.submit(AbstractListeningExecutorService.java:61) > at > com.datastax.driver.core.SessionManager.forceRenewPool(SessionManager.java:224) > at com.datastax.driver.core.Cluster$Manager.onUp(Cluster.java:1469) > at > com.datastax.driver.core.Cluster$Manager.access$1100(Cluster.java:1144) > at > com.datastax.driver.core.Cluster$Manager$4.runMayThrow(Cluster.java:1562) > at > com.datastax.driver.core.ExceptionCatchingRunnable.run(ExceptionCatchingRunnable.java:32) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) > at java.util.concurrent.FutureTask.run(FutureTask.java:262) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:745) > Caused by: com.datastax.driver.core.TransportException: [/127.0.0.1:9042] > Error writing: Closed channel > at > com.datastax.driver.core.Connection$1.operationComplete(Connection.java:432) > at > org.jboss.netty.channel.DefaultChannelFuture.notifyListener(DefaultChannelFuture.java:427) > at > org.jboss.netty.channel.DefaultChannelFuture.notifyListeners(DefaultChannelFuture.java:413) > at > org.jboss.netty.channel.DefaultChannelFuture.setFailure(DefaultChannelFuture.java:380) > at > org.jboss.netty.channel.socket.nio.AbstractNioWorker.write0(AbstractNioWorker.java:248) > at > org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromTaskLoop(AbstractNioWorker.java:151) > at > org.jboss.netty.channel.socket.nio.AbstractNioChannel$WriteTask.run(AbstractNioChannel.java:335) > at > org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:372) > at > org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:296) > at > org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) > at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) > at > org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) > at > org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) > ... 3 more > 15/05/10 12:20:08 ERROR ControlConnection: [Control connection] Cannot > connect to any host, scheduling retry in 1000 milliseconds > > Thanks! > > 2015-05-10 0:58 GMT+02:00 Gerard Maas <gerard.m...@gmail.com>: > >> Hola Sergio, >> >> It would help if you added the error message + stack trace. >> >> -kr, Gerard. >> >> On Sat, May 9, 2015 at 11:32 PM, Sergio Jiménez Barrio < >> drarse.a...@gmail.com> wrote: >> >>> I am trying save some data in Cassandra in app with spark Streaming: >>> >>> Messages.foreachRDD { >>> . . . >>> CassandraRDD.saveToCassandra("test","test") >>> } >>> >>> When I run, the app is closes when I recibe data or can't connect with >>> Cassandra. >>> >>> Some idea? Thanks >>> >>> >>> -- >>> Atte. Sergio Jiménez >>> >> >> >
