Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (nike.apache.org: domain of jbellis@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:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=WWReY77u8nFgZChS7tmPm6i3ySYUuvWmCD1XYa9Mnvuw2qguzGTmOYsmwOfvwTqMdR
         chpAwORZ3P2qGJ1RUvq+uKMYC0smtDtzfAmSh8VajtIkACMxDniYHr9GUpAQ956NotDL
         UnOa1eUjKCWa4I0RsnWvSYkVJbwX9rawT/JIY=
MIME-Version: 1.0
In-Reply-To: <AANLkTimmOYLZREFp+1RkcVd2bkXb_eGUBe7imqoe1X5x@mail.gmail.com>
References: <AANLkTik4KPJe7oyjzA5AZQpcbC8Z3soOfb9R4_4AVent@mail.gmail.com>
 <AANLkTim6hzJZEOczAfQXCphXY9+ewPnP48NGLvjzu_nT@mail.gmail.com>
 <AANLkTi=SXy+bhmFHDTER1nzuegVcC4WqKsrZDUpgxR=5@mail.gmail.com>
 <AANLkTimmOYLZREFp+1RkcVd2bkXb_eGUBe7imqoe1X5x@mail.gmail.com>
From: Jonathan Ellis <jbellis@gmail.com>
Date: Tue, 7 Sep 2010 21:05:48 -0500
Message-ID: <AANLkTimyDE07nECA7SKHSwwZVA+K=4vXZKsbkPEXHr0x@mail.gmail.com>
Subject: Re: batch_mutate silently failing in Cassandra
To: user@cassandra.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

QUORUM of ReplicationFactor=3D1 is 1.  All consistency levels should
work fine as long as RF <=3D node count.  If you are seeing it work at
CL.ONE but not at QUORUM then that is probably a bug.

On Tue, Sep 7, 2010 at 7:36 PM, Lucas Nodine <lucasnodine@gmail.com> wrote:
> Partially Resolved...
>
> Taking your advise (both Jonathan and Aaron's) I was able to track the
> problem down.=A0 The issue was that running insert (also batch_mutate) an=
d
> using a consistencylevel of quorum on a cluster of=A01 server with a
> replication factor of 1 does not work.=A0 Well, that is not accurate, let=
 me
> explain.=A0 I believe the problem lies in the description of QUORUM as de=
fined
> in the API on the wiki "Ensure that the write has been written to N=A0/=
=A02=A0+=A01
> replicas before responding to the client."
>
> 1/2+1 =3D 1.5 -- One server can never accomplish this.=A0 I believe I rea=
d
> something about this somewhere in all the documentation, but it would be
> really handy to have received an error telling me that it was impossible
> (assuming this was actually the issue).=A0 I am by far, not familiar with=
 the
> replication model, but if it is not by design, someone let me know and I'=
ll
> report it.
>
> Thx,
>
> - LN
>
> On Tue, Sep 7, 2010 at 3:00 PM, Lucas Nodine <lucasnodine@gmail.com> wrot=
e:
>>
>> Jonathan,
>>
>> I have done it successfully with insert, but I have not tried it with
>> mutate.=A0 I'll give that a try tonight.
>>
>> Thanks
>> On Tue, Sep 7, 2010 at 2:54 PM, Jonathan Ellis <jbellis@gmail.com> wrote=
:
>>>
>>> I would try to get a single hard-coded column to insert, before doing
>>> something more complex.
>>>
>>> You can also enable debug logging on the server and see if that
>>> matches what you want the client to be doing.
>>>
>>> On Tue, Sep 7, 2010 at 9:11 AM, Lucas Nodine <lucasnodine@gmail.com>
>>> wrote:
>>> > Hello all,
>>> >
>>> > I have=A0posted the following to Stackoverflow, but thought that I wo=
uld
>>> > also
>>> > try the list.=A0 If you have any suggestions, please let me know
>>> >
>>> > I am working with Cassandra 0.6.5 using the thrift interface. I am
>>> > trying to
>>> > use the batch_mutate method call, however, when I execute it, I recei=
ve
>>> > no
>>> > error message. This leads me to believe it worked. When I check using
>>> > the
>>> > CLI, there is nothing there. Is there something wrong with my code or
>>> > format
>>> > of the mutation_map that anyone can see? Any ideas?
>>> >
>>> > Thanks in advance,
>>> >
>>> > LN
>>> >
>>> > public void Update(string keyspace, Common.NetworkPackage.MetaAsset m=
a)
>>> > {
>>> > =A0 Dictionary<string, Dictionary<string, List<Mutation>>> package;
>>> > =A0 Dictionary<string, List<Mutation>> packageEntry;
>>> > =A0 Dictionary<string, object>.Enumerator en;
>>> > =A0 List<Mutation> mutList;
>>> > =A0 Mutation mut;
>>> > =A0 DateTime now =3D DateTime.Now;
>>> >
>>> > =A0 if(!ma.Fields.ContainsKey("$guid"))
>>> > =A0 =A0 throw new ArgumentException("The field $guid is not present")=
;
>>> >
>>> > =A0 mutList =3D new List<Mutation>();
>>> > =A0 en =3D ma.Fields.GetEnumerator();
>>> >
>>> > =A0 while(en.MoveNext())
>>> > =A0 {
>>> > =A0 =A0 if (en.Current.Value =3D=3D null)
>>> > =A0 =A0 =A0 continue;
>>> > =A0 =A0 mut =3D new Mutation();
>>> > =A0 =A0 mut.Column_or_supercolumn =3D new ColumnOrSuperColumn();
>>> > =A0 =A0 mut.Column_or_supercolumn.Column =3D new Column();
>>> > =A0 =A0 mut.Column_or_supercolumn.Column.Name =3D
>>> > _utf8.GetBytes(en.Current.Key);
>>> >
>>> > =A0 =A0 if (en.Current.Value =3D=3D null)
>>> > =A0 =A0 =A0 mut.Column_or_supercolumn.Column.Value =3D null;
>>> > =A0 =A0 else
>>> > =A0 =A0 =A0 mut.Column_or_supercolumn.Column.Value =3D
>>> > ToBytes(en.Current.Value);
>>> >
>>> > =A0 =A0 mut.Column_or_supercolumn.Column.Timestamp =3D
>>> > Utilities.Timestamp(now);
>>> >
>>> > =A0 =A0 mutList.Add(mut);
>>> > =A0 }
>>> >
>>> > =A0 packageEntry =3D new Dictionary<string, List<Mutation>>();
>>> > =A0 packageEntry.Add("MetaAsset", mutList);
>>> >
>>> > =A0 package =3D new Dictionary<string, Dictionary<string,
>>> > List<Mutation>>>();
>>> > =A0 package.Add((string)ma.Fields["$guid"], packageEntry);
>>> >
>>> > =A0 Console.WriteLine(Utilities.ExportBulkMutate("LawOffice", package=
));
>>> >
>>> > =A0 _client.batch_mutate(keyspace, package, ConsistencyLevel.QUORUM);
>>> > }
>>> >
>>> > The above code produces (columns are name:value @ timestamp, value
>>> > consists
>>> > of a type:and a representation of the actual value):
>>> >
>>> > LawOffice : {
>>> > =A0Row=3D08469fba50f448be8943614abd059d10 : {
>>> > =A0 =A0CF=3DMetaAsset : {
>>> > =A0 =A0 $guid : String:08469fba50f448be8943614abd059d10 @ 93
>>> > =A0 =A0 $creator : String:Lucas @ 93
>>> > =A0 =A0 $previousversion : String:00000000000000000000000000000000 @ =
93
>>> > =A0 =A0 $nextversion : String:00000000000000000000000000000000 @ 93
>>> > =A0 =A0 $etag : String:0 @ 93
>>> > =A0 =A0 $length : Int32:123456789 @ 93
>>> > =A0 =A0 $extension : String:.odt @ 93
>>> > =A0 =A0 $created : DateTime:90 @ 93
>>> > =A0 =A0 $modified : DateTime:90 @ 93
>>> > =A0 =A0 $lastaccess : DateTime:90 @ 93
>>> > =A0 =A0 $title : String:Title @ 93
>>> > =A0 =A0 $tags : List`1:tag1,tag2,tag3 @ 93
>>> > =A0 =A0}
>>> > =A0}
>>> > }
>>> >
>>> >
>>>
>>>
>>>
>>> --
>>> Jonathan Ellis
>>> Project Chair, Apache Cassandra
>>> co-founder of Riptano, the source for professional Cassandra support
>>> http://riptano.com
>


--=20
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com