Please give an example of the code you are trying to execute.
On Thu, May 16, 2013 at 6:26 PM, Everton Lima <peitin.inu...@gmail.com>wrote: > But the problem is that I would like to use Cassandra embeeded? This is > not possible any more? > > > 2013/5/15 Edward Capriolo <edlinuxg...@gmail.com> > >> >> 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 >>> >>> >> > > > -- > Everton Lima Aleixo > Bacharel em Ciência da Computação pela UFG > Mestrando em Ciência da Computação pela UFG > Programador no LUPA > >
