Return-Path: X-Original-To: apmail-cassandra-user-archive@www.apache.org Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 9CD8D8062 for ; Mon, 8 Aug 2011 02:52:01 +0000 (UTC) Received: (qmail 63801 invoked by uid 500); 8 Aug 2011 02:51:57 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 63473 invoked by uid 500); 8 Aug 2011 02:51:54 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 63465 invoked by uid 99); 8 Aug 2011 02:51:53 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Aug 2011 02:51:53 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of yulinyen@gmail.com designates 209.85.215.44 as permitted sender) Received: from [209.85.215.44] (HELO mail-ew0-f44.google.com) (209.85.215.44) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Aug 2011 02:51:47 +0000 Received: by ewy19 with SMTP id 19so775341ewy.31 for ; Sun, 07 Aug 2011 19:51:27 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=yS3xDrF//KUZVcAPeY+OTQD76+VedXR0oRs+QwZwFok=; b=bNFY5dd720y0wQM5Viy+my4sbbNCDueYrltrR6uMeHJ2EStnBzDnqFzG+AXmAt+3/c t6zCMjT590oxGjeJg4nYShFJv33mqcURaxzmQJBGurdW4QJqwefQKQKTQp/JSPtEuYRL lAj0dtpafz4wFmOqrKJ7E/bvm8ZXkutSFAG7w= MIME-Version: 1.0 Received: by 10.14.99.70 with SMTP id w46mr1300087eef.73.1312771887320; Sun, 07 Aug 2011 19:51:27 -0700 (PDT) Received: by 10.14.45.8 with HTTP; Sun, 7 Aug 2011 19:51:27 -0700 (PDT) In-Reply-To: References: Date: Mon, 8 Aug 2011 10:51:27 +0800 Message-ID: Subject: Re: batch mutates & throughput From: Boris Yen To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=bcaec52be7ad03cf1b04a9f5864e X-Virus-Checked: Checked by ClamAV on apache.org --bcaec52be7ad03cf1b04a9f5864e Content-Type: text/plain; charset=ISO-8859-1 Maybe you could try to adjust the setting "cassandraThriftSocketTimeout" of hector. https://github.com/rantav/hector/wiki/User-Guide On Mon, Aug 8, 2011 at 6:54 AM, Philippe wrote: > Quick followup. > I have pushed the RPC timeout to 30s. Using Hector, I'm doing 1 thread > doing batches of 10 mutates at a time so that's even slower than when I was > doing 16 threads in parallel doing non-batched mutations. > After a couple hundred execute() calls, I get a timeout for every node; I > have a 15 second grace period between retries. tpstats indicate no pendings > on any of the nodes. I never recover from that > > I then set the batch size to one and it seems to work a lot better. The > only difference I note is that the Mutator.execute() method returns a result > than sometimes has a null host and 0 microsecond time in the batch sizes of > ten but never in batch sizes of 1. > > > I'm stumped ! Any ideas ? > > Thanks > --bcaec52be7ad03cf1b04a9f5864e Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Maybe you could try to adjust the setting "cassandraThr= iftSocketTimeout" of hector.=A0https://github.com/rantav/hector/wiki/User-Guide=


On Mon, Aug 8, 2011 at 6= :54 AM, Philippe <watcherfr@gmail.com> wrote:
Quick followup.
I have pushed the RPC timeout to 30s.=A0Using Hector, I= 'm doing 1 thread doing batches of 10 mutates at a time so that's e= ven slower than when I was doing 16 threads in parallel doing non-batched m= utations.
After a couple hundred execute() calls, I get a timeout for every node; I h= ave a 15 second grace period between retries. tpstats indicate no pendings = on any of the nodes. I never recover from that

I then set the batch size to one and it seems to work a lot better. The onl= y difference I note is that the Mutator.execute() method returns a result t= han sometimes has a null host and 0 microsecond time in the batch sizes of = ten but never in batch sizes of 1.


I'm stumped ! Any ideas ?
=
Thanks

--bcaec52be7ad03cf1b04a9f5864e--