I looked at the thrift service implementation and got it working.
(Much faster import!)
Thanks!
On Mon, Jun 21, 2010 at 13:09, Oleg Anastasjev <olega...@gmail.com> wrote:
> Torsten Curdt <tcurdt <at> vafer.org> writes:
>
>>
>> First I tried with my one "cassandra -f" instance then I saw this
>> requires a separate IP. (Why?)
>
> This is because your import program becomes a special member of cassandra
> cluster to be able to speak internal protocol. And each memboer of cassandra
> cluster must have its own IP.
>
>> But even with a separate IPs
>> "StorageService.instance.getNaturalEndpoints" does not return an
>> endpoint.
>
> Did you defined -Dstorage-config for your import program to point to the same
> configuration your normal cassandra nodes use ?
>
> Did you initialized client-mode storage service, like below ?
> // init cassandra proxy
> try
> {
> StorageService.instance.initClient();
> }
> catch (IOException e)
> {
> throw new RuntimeException(e);
> }
> try
> {
> Thread.sleep(10*1000);
> }
> catch (InterruptedException e)
> {
> throw new RuntimeException(e);
> }
>
>
>
>
