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 > >
