Exception in thread event_loop
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
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
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
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