incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Everton Lima <peitin.inu...@gmail.com>
Subject Re: Upgrade 1.1.10 -> 1.2.4
Date Thu, 16 May 2013 22:26:03 GMT
But the problem is that I would like to use Cassandra embeeded? This is not
possible any more?


2013/5/15 Edward Capriolo <edlinuxguru@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.inutil@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 <edlinuxguru@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.inutil@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

Mime
View raw message