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 758624167 for ; Tue, 31 May 2011 07:46:40 +0000 (UTC) Received: (qmail 84753 invoked by uid 500); 31 May 2011 07:46:38 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 84147 invoked by uid 500); 31 May 2011 07:46:30 -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 84139 invoked by uid 99); 31 May 2011 07:46:29 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 31 May 2011 07:46:29 +0000 X-ASF-Spam-Status: No, hits=3.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,RFC_ABUSE_POST,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of zhangyf2007@gmail.com designates 209.85.212.44 as permitted sender) Received: from [209.85.212.44] (HELO mail-vw0-f44.google.com) (209.85.212.44) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 31 May 2011 07:46:23 +0000 Received: by vws12 with SMTP id 12so4283081vws.31 for ; Tue, 31 May 2011 00:46:02 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:date:message-id:subject:from:to :content-type; bh=1xwfpemuzKOy7UE4qmWQzVXKICfqUH4ljSd0ozIoMXs=; b=WW3zq2CdnXHaOY3g5EakhBiQAJGwXR+hNmbkujyHdLH7ceZTMdv/FD2pE2nKgru0gQ pTGH9QuKNh9xeyfVnJZJnD0exDH3HZ7LiAmzkNdd7Ljzzifyg8MJrOCRU2s288i5Zijc cx/z9kyGK9jTviQN5BV+k1qRhgbJ2POr1AaL8= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:date:message-id:subject:from:to:content-type; b=B9MfGTJs6A9nAwyybb9HGzzuwRc6OchRTwjSJZR2IRl32bb3ApsZrAfBk9k08Dpo0S zQ+wSzeKFDVX7nPletO0hQty/7n2IGifqrD70JqXiIM+gXj46AKBZZlyhP6tgpntkpXm Nl6bY1nOLhEkmqYopNoyb1d8Bh503G0EJCtyg= MIME-Version: 1.0 Received: by 10.52.107.129 with SMTP id hc1mr5643592vdb.173.1306827938299; Tue, 31 May 2011 00:45:38 -0700 (PDT) Received: by 10.52.158.202 with HTTP; Tue, 31 May 2011 00:45:38 -0700 (PDT) Date: Tue, 31 May 2011 15:45:38 +0800 Message-ID: Subject: sync commitlog in batch mode lose data From: Preston Chang To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=bcaec54862660b7ef604a48d9759 --bcaec54862660b7ef604a48d9759 Content-Type: text/plain; charset=ISO-8859-1 Hi, I have a cluster with two nodes (node A and node B) and make a test as follows: 1). set commitlog sync in batch mode and the sync batch window in 0 ms 2). one client wrote random keys in infinite loop with consistency level QUORUM and record the keys in file after the insert() method return normally 3). unplug one server (node A) power cord 4). restart the server and cassandra service 5). read the key list generated in step 2) with consistency level ONE I thought the result of test is all the key in list can be read normally, but actually there are some NotFound keys. My question is why there are NotFound keys. In my opinion server would not ack the client before finishing syncing the commitlog if I set commitlog sync in batch mode and the sync batch window in 0 ms. So if the insert() method return normally it means the mutation had been written in commitlog and the commitlog had been synced to the disk. Am I right? My Cassandra version is 0.7.3. Thanks for your help very much. -- by Preston Chang --bcaec54862660b7ef604a48d9759 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi,

I have a cluster with two nodes (node A a= nd node B) and make a test as follows:

1). set com= mitlog sync in batch mode and the sync batch window in 0 ms
2). o= ne client wrote random keys in infinite loop with consistency level QUORUM = and record the keys in file after the insert()=A0method return normally
3). unplug one server (node A) power cord
4). restart the se= rver and cassandra service
5). read the key list generated in ste= p 2) with consistency level ONE

I thought the resu= lt of test is all the key in list can be read normally, but actually there = are some NotFound keys.

My question is why there are NotFound keys. In my opini= on server would not ack the client before finishing syncing the commitlog i= f=A0I set commitlog sync in batch mode and the sync batch window in 0 ms. S= o if the insert() method return normally it means the=A0mutation had been w= ritten in commitlog and the commitlog had been synced to the disk. Am I rig= ht?

My Cassandra version is 0.7.3.

Thanks for your help very much.

--
by Preston Chang

--bcaec54862660b7ef604a48d9759--