Exception in thread event_loop

2014-03-16 Thread Sundeep Kambhampati 
Hi,

I am using cassandra-2.0.4.

When I execute following python code, I often get an exception mentioned
below. Sometimes it works fine but most of the times it throws an error.
All the nodes are up and running. Data in second column of table is huge,
few thousand characters long and there around 10K rows.

Code :

from cassandra.cluster import Cluster

cluster = Cluster(['10.2.252.0', '10.2.252.1'])
session = cluster.connect('test')

str = SELECT * FROM users ;
rows = session.execute(str)

for user_row in rows:
print user_row.f_id, user_row.data

cluster.shutdown()

Exception:

Exception in thread event_loop (most likely raised during interpreter
shutdown):
Traceback (most recent call last):
  File /usr/local/lib/python2.7/threading.py, line 810, in
__bootstrap_inner
  File /usr/local/lib/python2.7/threading.py, line 763, in run
  File
/usr/local/lib/python2.7/site-packages/cassandra/io/asyncorereactor.py,
line 52, in _run_loop
type 'exceptions.AttributeError': __exit__


Can someone help me fixing this error?

Regards,
Sundeep

Re: Exception in thread event_loop

2014-03-16 Thread Sundeep Kambhampati 
Thank you for the reply. I installed libev. However, it throwing a new
exception. I searched online but couldn't find much help.

  File Utils/readDataCassandra.py, line 6, in module
from cassandra.io.libevreactor import LibevConnection
  File
/usr/local/lib/python2.7/site-packages/cassandra/io/libevreactor.py, line
17, in module
import cassandra.io.libevwrapper as libev
ImportError:
/usr/local/lib/python2.7/site-packages/cassandra/io/libevwrapper.so:
undefined symbol: ev_run

Can you please help me with this?

Regards,
Sundeep




On Sun, Mar 16, 2014 at 8:33 PM, Laing, Michael
michael.la...@nytimes.comwrote:

 A possible workaround - not a fix - might be to install libev so the libev
 event loop is used.

 See http://datastax.github.io/python-driver/installation.html

 Also be sure you are running the latest version: 1.0.2 I believe.

 Your ';' is outside of your 'str' - actually shouldn't be a problem tho.

 Good luck!
 ml


 On Sun, Mar 16, 2014 at 8:19 PM, Sundeep Kambhampati 
 satyasunde...@gmail.com wrote:

 Hi,

 I am using cassandra-2.0.4.

 When I execute following python code, I often get an exception mentioned
 below. Sometimes it works fine but most of the times it throws an error.
 All the nodes are up and running. Data in second column of table is huge,
 few thousand characters long and there around 10K rows.

 Code :

 from cassandra.cluster import Cluster

 cluster = Cluster(['10.2.252.0', '10.2.252.1'])
 session = cluster.connect('test')

 str = SELECT * FROM users ;
 rows = session.execute(str)

 for user_row in rows:
 print user_row.f_id, user_row.data

 cluster.shutdown()

 Exception:

 Exception in thread event_loop (most likely raised during interpreter
 shutdown):
 Traceback (most recent call last):
   File /usr/local/lib/python2.7/threading.py, line 810, in
 __bootstrap_inner
   File /usr/local/lib/python2.7/threading.py, line 763, in run
   File
 /usr/local/lib/python2.7/site-packages/cassandra/io/asyncorereactor.py,
 line 52, in _run_loop
 type 'exceptions.AttributeError': __exit__


 Can someone help me fixing this error?

 Regards,
 Sundeep

Fwd: Unable to gossip with any seeds

2014-02-03 Thread Sundeep Kambhampati 
Hi,

I am trying to setup multi-node Cassandra cluster (2 nodes). I am
using apache-cassandra-2.0.4. I am able to start Cassandra on the seed
node. But, when I am trying to start it on the other node it starts and
fails in few seconds. I can see the following in my error log:

ERROR 03:23:56,915 Exception encountered during startup
java.lang.RuntimeException: Unable to gossip with any seeds 


I am able to telnet from node 1 to node 0.

telnet 10.2.252.0 9000
Trying 10.2.252.0...
Connected to 10.2.252.0.
Escape character is '^]'.
^]
Connection closed by foreign host.


*cassandra.yaml*

node 0: (sk.r252.0)(seed)

cluster_name: 'DataCluster'
num_tokens: 256
initial_token: 0
seeds: sk.r252.0
storage_port: 9000
ssl_storage_port: 9001
listen_address: sk.r252.0
rpc_address: 0.0.0.0
rpc_port: 8192
endpoint_snitch: RackInferringSnitch

node 1: (sk.r252.1)
cluster_name: 'DataCluster'
num_tokens: 256
initial_token: 4611686018427387904
seeds: sk.r252.0
storage_port: 9000
ssl_storage_port: 9001
listen_address: sk.r252.1
rpc_address: 0.0.0.0
rpc_port: 8192
endpoint_snitch: RackInferringSnitch


When I am trying to start Cassandra on node 1 it fails and the log shows:

 INFO 03:23:25,284 Loading persisted ring state
 INFO 03:23:25,564 Starting Messaging Service on port 9000
 INFO 03:23:25,797 Handshaking version with sk.r252.0/10.2.252.0
ERROR 03:23:56,915 Exception encountered during startup
java.lang.RuntimeException: Unable to gossip with any seeds
at
org.apache.cassandra.gms.Gossiper.doShadowRound(Gossiper.java:1160)
at
org.apache.cassandra.service.StorageService.checkForEndpointCollision(StorageService.java:426)
at
org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:618)
at
org.apache.cassandra.service.StorageService.initServer(StorageService.java:586)
at
org.apache.cassandra.service.StorageService.initServer(StorageService.java:485)
at
org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:346)
at
org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:461)
at
org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:504)
java.lang.RuntimeException: Unable to gossip with any seeds
at
org.apache.cassandra.gms.Gossiper.doShadowRound(Gossiper.java:1160)
at
org.apache.cassandra.service.StorageService.checkForEndpointCollision(StorageService.java:426)
at
org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:618)
at
org.apache.cassandra.service.StorageService.initServer(StorageService.java:586)
at
org.apache.cassandra.service.StorageService.initServer(StorageService.java:485)
at
org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:346)
at
org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:461)
at
org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:504)
Exception encountered during startup: Unable to gossip with any seeds
ERROR 03:24:02,213 Exception in thread
Thread[StorageServiceShutdownHook,5,main]
java.lang.NullPointerException
at
org.apache.cassandra.service.StorageService.stopNativeTransport(StorageService.java:349)
at
org.apache.cassandra.service.StorageService.shutdownClientServers(StorageService.java:364)
at
org.apache.cassandra.service.StorageService.access$000(StorageService.java:97)
at
org.apache.cassandra.service.StorageService$1.runMayThrow(StorageService.java:551)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
at java.lang.Thread.run(Unknown Source)

*bin/nodetool status*


Datacenter: 0
=
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
--  Address   Load   Owns (effective)  Host ID
  TokenRack
UN  10.0.2.1  35.8 KB100.0%
 0ae766db-fcb5-481b-8120-550b672fa9e7  0
 2


Can some please help me fixing this error?


Thank you,
Sundeep

Re: Unable to gossip with any seeds

2014-02-03 Thread Sundeep Kambhampati 
Thank you Chiru for the reply. I am configuring single datacenter. I
changed it to SimpleSnitch. However, I am getting the same error.

-Sundeep


On Mon, Feb 3, 2014 at 3:58 AM, Chiranjeevi Ravilla rccassandr...@gmail.com
 wrote:

 Hi Sundeep,

 Can you please confirm, are you configuring two nodes in different
 Datacenters?

 If you are configuring on single datacenter with two nodes,then please
 change the endpoint_snitch  from  RackInferringSnitch to SimpleSnitch and
 restart the clusters.

 Regards,
 Chiru

 On 03-Feb-2014, at 2:17 PM, Sundeep Kambhampati satyasunde...@gmail.com
 wrote:

 Hi,

 I am trying to setup multi-node Cassandra cluster (2 nodes). I am
 using apache-cassandra-2.0.4. I am able to start Cassandra on the seed
 node. But, when I am trying to start it on the other node it starts and
 fails in few seconds. I can see the following in my error log:

 ERROR 03:23:56,915 Exception encountered during startup
 java.lang.RuntimeException: Unable to gossip with any seeds 


 I am able to telnet from node 1 to node 0.

 telnet 10.2.252.0 9000
 Trying 10.2.252.0...
 Connected to 10.2.252.0.
 Escape character is '^]'.
 ^]
 Connection closed by foreign host.


 *cassandra.yaml*

 node 0: (sk.r252.0)(seed)

 cluster_name: 'DataCluster'
 num_tokens: 256
 initial_token: 0
 seeds: sk.r252.0
 storage_port: 9000
 ssl_storage_port: 9001
 listen_address: sk.r252.0
 rpc_address: 0.0.0.0
 rpc_port: 8192
 endpoint_snitch: RackInferringSnitch

 node 1: (sk.r252.1)
 cluster_name: 'DataCluster'
 num_tokens: 256
 initial_token: 4611686018427387904
 seeds: sk.r252.0
 storage_port: 9000
 ssl_storage_port: 9001
 listen_address: sk.r252.1
 rpc_address: 0.0.0.0
 rpc_port: 8192
 endpoint_snitch: RackInferringSnitch


 When I am trying to start Cassandra on node 1 it fails and the log shows:

  INFO 03:23:25,284 Loading persisted ring state
  INFO 03:23:25,564 Starting Messaging Service on port 9000
  INFO 03:23:25,797 Handshaking version with sk.r252.0/10.2.252.0
 ERROR 03:23:56,915 Exception encountered during startup
 java.lang.RuntimeException: Unable to gossip with any seeds
 at
 org.apache.cassandra.gms.Gossiper.doShadowRound(Gossiper.java:1160)
 at
 org.apache.cassandra.service.StorageService.checkForEndpointCollision(StorageService.java:426)
 at
 org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:618)
  at
 org.apache.cassandra.service.StorageService.initServer(StorageService.java:586)
 at
 org.apache.cassandra.service.StorageService.initServer(StorageService.java:485)
 at
 org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:346)
 at
 org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:461)
 at
 org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:504)
 java.lang.RuntimeException: Unable to gossip with any seeds
 at
 org.apache.cassandra.gms.Gossiper.doShadowRound(Gossiper.java:1160)
 at
 org.apache.cassandra.service.StorageService.checkForEndpointCollision(StorageService.java:426)
 at
 org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:618)
 at
 org.apache.cassandra.service.StorageService.initServer(StorageService.java:586)
 at
 org.apache.cassandra.service.StorageService.initServer(StorageService.java:485)
 at
 org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:346)
 at
 org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:461)
 at
 org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:504)
 Exception encountered during startup: Unable to gossip with any seeds
 ERROR 03:24:02,213 Exception in thread
 Thread[StorageServiceShutdownHook,5,main]
 java.lang.NullPointerException
 at
 org.apache.cassandra.service.StorageService.stopNativeTransport(StorageService.java:349)
 at
 org.apache.cassandra.service.StorageService.shutdownClientServers(StorageService.java:364)
 at
 org.apache.cassandra.service.StorageService.access$000(StorageService.java:97)
 at
 org.apache.cassandra.service.StorageService$1.runMayThrow(StorageService.java:551)
 at
 org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
 at java.lang.Thread.run(Unknown Source)

 *bin/nodetool status*


 Datacenter: 0
 =
 Status=Up/Down
 |/ State=Normal/Leaving/Joining/Moving
 --  Address   Load   Owns (effective)  Host ID
   TokenRack
 UN  10.0.2.1  35.8 KB100.0%
  0ae766db-fcb5-481b-8120-550b672fa9e7  0
  2


 Can some please help me fixing this error?


 Thank you,
 Sundeep