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);
}