Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (athena.apache.org: domain of atul.gosain@gmail.com
 designates 209.85.212.44 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:date:message-id:subject:from:to:content-type;
        b=XkSImg8DUHaJwa6wYjNMHynPVX6ZdsRTNr+F5cNIMClHv0SXFd4kOdCjkM4tUVMryi
         6g+8+fbuIVXf8NJPMglr3CQuglz4bhYLd527ilB5jqojnfDvk9fkqIv8b6p9mDEBKIkF
         8B6p1kNh/6bgeM9xRuSeUq/NCrDQYX9lv4zVY=
MIME-Version: 1.0
Date: Sun, 27 Jun 2010 16:23:15 +0530
Message-ID: <AANLkTil50-KWgyaDaeFGL9jow6WmCdIAm9Xur3zplkIX@mail.gmail.com>
Subject: Hector Client Failover errors
From: Atul Gosain <atul.gosain@gmail.com>
To: user@cassandra.apache.org
Content-Type: multipart/alternative; boundary=0016e68ee95aa7b37d048a00cf6e

--0016e68ee95aa7b37d048a00cf6e
Content-Type: text/plain; charset=ISO-8859-1

I am trying to insert the data using hector client. Using only one host in
the pool ie. localhost. like as follows
            CassandraClientPool pool =
CassandraClientPoolFactory.INSTANCE.get();
            client = pool.borrowClient("localhost", 9160);
            global = client.getKeyspace(keyspace, ConsistencyLevel.ONE);


After some(5-6) iterations of insertions of data (every 5 min insertion of
about 40 MB of data), the program starts emitting this

10/06/27 09:55:28 WARN service.FailoverOperator: Got a TTransportException
from localhost. Num of retries: 1
10/06/27 09:55:28 INFO service.FailoverOperator: Skipping to next host.
Current host is: localhost
10/06/27 09:55:28 INFO service.FailoverOperator: Skipped host. New host is:
localhost

I couldnt understand the reason for this, when im using only device in the
pool. If i remove the ConsistencyLevel.ONE, then the error starts from the
first iteration itself.

The same program through Thrift runs without any problems. Actually, i just
modified the thrift program and replaced the calls to thrift api to
corresponding Hector calls.

Thanks
Atul

--0016e68ee95aa7b37d048a00cf6e
Content-Type: text/html; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

I am trying to insert the data using hector client. Using only one host in =
the pool ie. localhost. like as follows <br>=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 CassandraClientPool pool =3D CassandraClientPoolFactory.INSTANCE.get();=
<br>=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 client =3D pool.borrowClient(&quot;lo=
calhost&quot;, 9160);<br>
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 global =3D client.getKeyspace(keyspace, C=
onsistencyLevel.ONE);<br><br><br>After some(5-6) iterations of insertions o=
f data (every 5 min insertion of about 40 MB of data), the program starts e=
mitting this <br><br>
10/06/27 09:55:28 WARN service.FailoverOperator: Got a TTransportException =
from localhost. Num of retries: 1<br>10/06/27 09:55:28 INFO service.Failove=
rOperator: Skipping to next host. Current host is: localhost<br>10/06/27 09=
:55:28 INFO service.FailoverOperator: Skipped host. New host is: localhost<=
br>
<br>I couldnt understand the reason for this, when im using only device in =
the pool. If i remove the ConsistencyLevel.ONE, then the error starts from =
the first iteration itself. <br><br>The same program through Thrift runs wi=
thout any problems. Actually, i just modified the thrift program and replac=
ed the calls to thrift api to corresponding Hector calls. <br>
<br>Thanks<br>Atul<br>

--0016e68ee95aa7b37d048a00cf6e--