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 Fri, 17 May 2013 03:14:06 GMT
Please give an example of the code you are trying to execute.


On Thu, May 16, 2013 at 6:26 PM, Everton Lima <peitin.inutil@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 <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