Return-Path: Delivered-To: apmail-incubator-cassandra-user-archive@minotaur.apache.org Received: (qmail 57226 invoked from network); 9 Dec 2009 11:17:18 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 9 Dec 2009 11:17:18 -0000 Received: (qmail 71877 invoked by uid 500); 9 Dec 2009 11:17:17 -0000 Delivered-To: apmail-incubator-cassandra-user-archive@incubator.apache.org Received: (qmail 71816 invoked by uid 500); 9 Dec 2009 11:17:17 -0000 Mailing-List: contact cassandra-user-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: cassandra-user@incubator.apache.org Delivered-To: mailing list cassandra-user@incubator.apache.org Received: (qmail 71807 invoked by uid 99); 9 Dec 2009 11:17:17 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Dec 2009 11:17:17 +0000 X-ASF-Spam-Status: No, hits=-2.4 required=5.0 tests=AWL,BAYES_00,HTML_MESSAGE X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of richiesgr@gmail.com designates 72.14.220.155 as permitted sender) Received: from [72.14.220.155] (HELO fg-out-1718.google.com) (72.14.220.155) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Dec 2009 11:17:15 +0000 Received: by fg-out-1718.google.com with SMTP id e21so1422063fga.0 for ; Wed, 09 Dec 2009 03:16:54 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:date:message-id:subject :from:to:content-type; bh=F88nd7AFMbk1y5G+6+e/DQP/zEJOJX+ky1+D2NizEno=; b=IulI9DxAwjW40PNAHDnfTlZZLPyocGWZeEyz1eIjQVws3Rwi7uPf5nIJKd0m35l8Cu 4Eljqknk5K0BNO7PLeHSKAaRpgB8Eal4DgFqRrbne7aDYDplrqqxX5ycvs9XlAfd5B9z dri20+09cjWIlOjFBgvmmF93NvspUzEBKU/xA= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:date:message-id:subject:from:to:content-type; b=aFEGczvvk0Ca5RMVwrwcxgwgFkve5wlrTo1ZegdW/91eU1VjNbL17Br+GhXlv4UTAf QeY24bUcAc30hQW7Lq2gRNJ4D37m0YHTA5Igs0xAw4q9XVRyQun3vL/kuVKdCPFQhLVU z2cSqaTEQcpSs2t1cZZCESQhalUbRPGyp9iG4= MIME-Version: 1.0 Received: by 10.239.184.157 with SMTP id y29mr961734hbg.54.1260357413692; Wed, 09 Dec 2009 03:16:53 -0800 (PST) Date: Wed, 9 Dec 2009 13:16:53 +0200 Message-ID: <468b21170912090316q6c3be9b0u767a22b220a9ece2@mail.gmail.com> Subject: Regarding Pending Task in MBeam Column family From: Richard Grossman To: cassandra-user@incubator.apache.org Content-Type: multipart/alternative; boundary=001485f79366eee4d8047a49d361 --001485f79366eee4d8047a49d361 Content-Type: text/plain; charset=ISO-8859-1 Hi what the purpose of pending task attribute value. In my case I've written a multi threaded client to insert a large dataset in cassandra. So I check the numbers in Jconsole. I see the write latency : ~0.02 ~0.07 Writecount up but the pending task stay to 0. This params is not affected by not insertion. By the way my problem is that I can't achieve to have better insert than 75 rows/s per thread. which ridiculous for cassandra. But more strange is that i can add more thread like 10 or 20 each of them work exactly to 75 rows/s so here I'm lost 1 thread > 75 rows /s 5 threads > 75 * 5 rows /s Someone can explain the logical here I use the 0.5.0-beta1 from tags Thanks --001485f79366eee4d8047a49d361 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi

what the purpose of pending task attribute value= . In my case I've written a multi threaded client to insert a large dat= aset in cassandra. So I check the numbers in Jconsole.

I see the wri= te latency : ~0.02 ~0.07
Writecount up

but the pending task stay to 0. This params is not aff= ected by not insertion.

By the way my problem is that I can't ac= hieve to have better insert than 75 rows/s per thread. which ridiculous for= cassandra. But more strange is that i can add more thread like 10 or 20 ea= ch of them work exactly to 75 rows/s

so here I'm lost 1 thread > 75 rows /s
=A0=A0=A0=A0=A0=A0=A0= =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 5 threads > 75 * 5 rows= /s

Someone can explain the logical here
I use the 0.5.0-beta1 f= rom tags

Thanks
=A0
--001485f79366eee4d8047a49d361--