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 Wed, 15 May 2013 21:13:25 GMT
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