incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Edward Capriolo <edlinuxg...@gmail.com>
Subject Re: Upgrade 1.1.10 -> 1.2.4
Date Thu, 16 May 2013 00:29:58 GMT
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
>
>

Mime
View raw message