You are doing something wrong. What I was suggesting is only a hack for unit tests. Your not supposed to interact with CassandraServer directly like that as a client. Download hector and use the correct client libraries.
On Wed, May 15, 2013 at 5:13 PM, Everton Lima <peitin.inu...@gmail.com>wrote: > But using this code: > > ThriftSessionManager.instance.setCurrentSocket(new > InetSocketAddress(9160)); > > I will need to execute this line every time that I need to do somiething > in Cassandra? Like update a collunm family. > > Thanks for reply. > > > 2013/5/15 Edward Capriolo <edlinuxg...@gmail.com> > >> If you are using hector it can setup the embedded server properly. >> >> When using the server directly inside cassandra I have run into a similar >> problem.. >> >> >> https://github.com/edwardcapriolo/cassandra/blob/range-tombstone-thrift/test/unit/org/apache/cassandra/thrift/EndToEndTest.java >> >> @BeforeClass >> public static void setup() throws IOException, InvalidRequestException, >> TException{ >> Schema.instance.clear(); // Schema are now written on disk and will be >> reloaded >> new EmbeddedCassandraService().start(); >> ThriftSessionManager.instance.setCurrentSocket(new >> InetSocketAddress(9160)); >> server = new CassandraServer(); >> server.set_keyspace("Keyspace1"); >> } >> >> >> >> On Wed, May 15, 2013 at 4:24 PM, Everton Lima <peitin.inu...@gmail.com>wrote: >> >>> Hello, someone can help me to use the Object CassandraServer() in >>> version 1.2.4?? >>> I was using this in version 1.1.10, and thats work, but was happening >>> something that I can not solve (sometimes my cpu up to 100% and stay >>> forever) so I decide to do the upgrade. >>> >>> I start the cassandra with EmbeededCassandraServer. >>> The actual error is: >>> when the code call >>> >>> public ThriftClientState currentSession() >>> { >>> SocketAddress socket = remoteSocket.get(); >>> assert socket != null; >>> >>> ThriftClientState cState = activeSocketSessions.get(socket); >>> if (cState == null) >>> { >>> cState = new ThriftClientState(); >>> activeSocketSessions.put(socket, cState); >>> } >>> return cState; >>> } >>> >>> the variable socket is null. This methos is calling with: >>> >>> CassandraServer cs = new CassandraServer(); >>> cs.describe_keyspace() >>> >>> -- >>> Everton Lima Aleixo >>> Bacharel em Ciência da Computação pela UFG >>> Mestrando em Ciência da Computação pela UFG >>> Programador no LUPA >>> >>> >> > > > -- > Everton Lima Aleixo > Bacharel em Ciência da Computação pela UFG > Mestrando em Ciência da Computação pela UFG > Programador no LUPA > >
