Hi Kaveh,

On Fri, Aug 9, 2013 at 7:54 PM, kaveh minooie <[email protected]> wrote:

>  :) yes I do regenerate the job file. I actually have scripts that makes
> a fresh copy of git and applies my changes and run ants to generate the job
> file every time I make a change. the cassandra cluster that I am trying to
> use here consist of 10 servers, and the Hadoop cluster on which I run the
> nutch has 11 nodes as well. as you can imagine every node or role for that
> matter is found through DNS and anything localhost is kinda meaningless
> here. ( the only things in my /etc/hosts files is localhost and 127...)
>

OK so in o.a.g.store.CassandraClient#initialize(), to define our Cassandra
cluster we are using Hector's CassandraHostConfigurator as follows

this.cluster =
HFactory.getOrCreateCluster(this.cassandraMapping.getClusterName(), new
CassandraHostConfigurator(this.cassandraMapping.getHostName()));

this.cassandraMapping.getHostName() is the host= attribute value which we
pick up from the MAPPING_FILE.
According to Hector Client's CassandraHostConfigurator Javadoc, Cassandra
host specificiations should be of the form

        /**
         * Creates a new {@code CassandraHostConfigurator} from the specified
hosts String, formatted as
   * {@code host[:port][,host[:port]...]}.
   * @param hosts The hosts to create {@link CassandraHost}s from.
         */



>
> I would be surprise if you remember me
>

Of course I do ;)

Don't worry we will get this sorted. Keep the questions coming. Try our
best to get the answers Kaveh.
Ta
Lewis

Reply via email to