But the problem is that I would like to use Cassandra embeeded? This is not possible any more?
2013/5/15 Edward Capriolo <[email protected]> > > 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 <[email protected]>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 <[email protected]> >> >>> 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 >>> <[email protected]>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 >> >> > -- Everton Lima Aleixo Bacharel em Ciência da Computação pela UFG Mestrando em Ciência da Computação pela UFG Programador no LUPA
