Re: Riak Java client question

Also, a property annotated with a Riak annotation was kept in the Json only if it has been explicitly annotated with @JsonProperty or has not been annotated with a Riak property. This was accomplished with the following code from the old client: static { RIAK_ANNOTATIONS.add(RiakK

Re: Riak Java client API

Hi Pratik, >From exception msg you are missing joda time jar, download one and put in your classpath. If you use maven it will download the dependency for you automatically. Hope this help. Ajax On Friday, 28 October 2016, Pratik Kulkarni wrote: > Hi All, > > I am working on a distributed file

Re: Riak Java client question

Hi Guido, I see that you opened up this PR, thanks - https://github.com/basho/riak-java-client/pull/631 Would you mind filing these questions in an issue on GitHub to continue the discussion there? https://github.com/basho/riak-java-client/issues/new Thanks! -- Luke Bakken Engineer lbak...@bas

Re: Riak Java Client

Thanks Alex Will do. The https://github.com/basho/riak-java-client/issues/512 is causing issues on several platforms at the moment Cheers Cos On Tuesday, 28 April 2015 at 03:39, Alex Moore wrote: > Hi Cos, > > We will continue to support and develop the Java client. > > With Roach's departu

Re: Riak Java Client

Hi Cos, We will continue to support and develop the Java client. With Roach's departure I'll be taking over development for it. I've been his understudy of sorts for about a year now, although my focus has been more towards the .NET and PHP clients as of late. >Consequently, if there's no one o

Re: Riak Java Client and Links

Yes found that after a while. Thank you Cos On Tuesday, 27 January 2015 at 14:45, Brian Roach wrote: > Cosmin, > > To use links with a POJO, there's an annotation: > > http://basho.github.io/riak-java-client/2.0.0/com/basho/riak/client/api/annotations/RiakLinks.html > > - Roach > > O

Re: Riak Java Client and Links

Cosmin, To use links with a POJO, there's an annotation: http://basho.github.io/riak-java-client/2.0.0/com/basho/riak/client/api/annotations/RiakLinks.html - Roach On Tue, Jan 27, 2015 at 4:29 AM, Cosmin Marginean wrote: > I am implementing a custom way to handle Riak Links using a Java Client

Re: Riak Java client counter object

Guido, There is no special way to list the values for all counters in a bucket. You will have to list the keys for the bucket (with a bucket type property ‘datatype=counter’) then fetch the values for those keys (e.g. via multi-fetch). Depending on your use case and the number of counters, you

Re: Riak Java client counter object

Hi, Following up on this question, is there a way to list (not multi-fetch, just list) the existing counters in a bucket? Regards, Guido. On 24/01/14 22:01, Dave Rusek wrote: Guido, I’m sorry, there are not currently any docs available. Rest assured they are a work in progress. In the mea

Re: Riak Java client counter object

Guido, I’m sorry, there are not currently any docs available. Rest assured they are a work in progress. In the meantime, please feel free to check-out the current pre-release [1]. The pre-release covers the low level API we have built on top of the PB interface. There is a start to a friendlier

Re: Riak Java Client: PBClientConfig.Builder is not a value

Aren't you missing the new operator? PBClientConfig pbcc = *new* PBClientConfig.Builder().withHost("127.0.0.1").build(); -Koushik On Mon, Oct 28, 2013 at 10:53 AM, Ari King wrote: > I'm following the java client > wiki(using Riak

Re: Riak Java client not returning deleted sibling

I still did not figure it out what's happening. I wrote a simple test that uses 3 Riak Java clients running on single machine. Each client connects to a different Riak node and uses the same converters, mutators etc as original code. I'm explicitly setting clientId and started updating single key.

Re: Riak Java client not returning deleted sibling

I tested that with curl. Should've mentioned that. The output shows there is no siblings for the key and returned header looks like this: < HTTP/1.1 200 OK < X-Riak-Vclock: a85hYGBgymDKBVIc84WrPgUFPS3IYEpkymNlWJZ4/DQfVIpNStsDKsUIlFoOksoCAA== < x-riak-index-oid_bin: 2a9691be-2f70-11e3-b746-c91c3800

Re: Riak Java client not returning deleted sibling

Daniel - Unfortunately returning the body from a store operation may not reflect all the replicas (and in the case of a concurrent write on two different nodes "may not" really means "probably doesn't"). If you do a subsequent fetch after sending both your writes you'll get back a single vclock

Re: Riak Java client not returning deleted sibling

Hi Brian Thanks for update. I'm using 1.1.3 now and still have some issues sibling related Two clients are updating the same key. Updated is my custom meta field, which should be merged to contain values from both clients (set) I see both client are doing fetch, resolving sibling (only 1 i.e. no

Re: Riak Java client not returning deleted sibling

Daniel - I'll get 1.1.3 out today; I'll post to the list. There's actually a couple other small things I need to squeeze in since we're going to do a release. Re: Setting the vclock on the tombstone in JSONConverter, you're right. It would only be an issue if you only had a tombstone, but it shou

Re: Riak Java client not returning deleted sibling

Thanks Brian for putting fix together so quickly. I think I found something else though. In JSONConverter I don't see vclock being set in toDomain() when converting deleted sibling? That vclock should be used for following delete if I understood it correctly? Also where can I download latest buil

Re: Riak Java client not returning deleted sibling

On Thu, Oct 3, 2013 at 10:32 AM, Daniel Iwan wrote: > Thanks Brian for quick response. > > As a side question, what is the best way to delete such an object i.e. once > I know one of the siblings has 'deleted' flag true because I fetched it? > Should I just use DomainBucket.delete(key) without pro

Re: Riak Java client not returning deleted sibling

Thanks Brian for quick response. As a side question, what is the best way to delete such an object i.e. once I know one of the siblings has 'deleted' flag true because I fetched it? Should I just use DomainBucket.delete(key) without providing any vclock? Would it wipe it from Riak or create yet an

Re: Riak Java client not returning deleted sibling

Daniel - Yeah, that is the case. When the ability to pass fetch/store/delete meta was added to DomainBucket way back when it appears that was missed. I'll add it and forward-port to 1.4.x as well and cut new jars. Should be avail by tomorrow morning at the latest. Thanks! - Roach On Thu, Oct 3,

Re: Riak Java client isKeyPresent function?

Guido, You can do a HEAD request to just get the object's metadata. In the PB api, there's a boolean `head` that you can set to do the same. It doesn't return the object's value(s) for either interface. Docs: PB: http://docs.basho.com/riak/latest/dev/references/protocol-buffers/fetch-object/#

Re: Riak Java client bug?

To ease the situation we have done some redesign to avoid locks contention (Internal to our app), cause we were writing too often in very short time to the same key (no siblings), so it might be a combination of LevelDB+AAE+2i streaming, tomorrow hopefully things are back to normal, the crash.l

Re: Riak Java client bug?

That option is for the connection timeout (i.e. when the connection pool makes a new connection to Riak). You can set the read timeout on the socket with the aforementioned withRequestTimeoutMillis() The default is the Java default, which is to say it'll block on the socket read until either ther

Re: Riak Java client bug?

Like this: withConnectionTimeoutMillis(5000).build(); Guido. On 25/09/13 18:08, Brian Roach wrote: Guido - When you say "the client is configured to time out" do you mean you're using PB and you set the SO_TIMEOUT on the socket via the PBClientConfig's withRequestTimeoutMillis()? - Roach

Re: Riak Java client bug?

Guido - When you say "the client is configured to time out" do you mean you're using PB and you set the SO_TIMEOUT on the socket via the PBClientConfig's withRequestTimeoutMillis()? - Roach On Wed, Sep 25, 2013 at 5:54 AM, Guido Medina wrote: > Hi, > > Streaming 2i indexes is not timing out, ev

Re: Riak Java Client 1.1.2 and 1.4.0

Fixed. Apparently I updated the ACL for 1.1.2 and not 1.4.0, sorry. Thanks, - Roach On Wed, Jul 24, 2013 at 7:53 PM, YN wrote: > Hi Brian, > > Thanks for putting the release together so quickly. It does not appear as > though the download is working (for the non maven files). It looks like > the

Re: Riak Java client 100% CPU

Daniel - Fixed. I swear I thought I had edited the ACL. Thanks, - Roach On Fri, Feb 15, 2013 at 6:08 AM, Daniel Iwan wrote: > Hi > > Thanks for that and also for building riak-client with all dependencies. > But I'm afraid S3 bucket is password protected or link expired since I'm > getting Acce

Re: Riak Java client 100% CPU

Hi Thanks for that and also for building riak-client with all dependencies. But I'm afraid S3 bucket is password protected or link expired since I'm getting AccessDenied on that 1.1.0 jar Daniel On 14 February 2013 17:22, Brian Roach wrote: > Daniel - > > Yes, sorry about that. This has been

Re: Riak Java client 100% CPU

Daniel - Yes, sorry about that. This has been corrected in the current master on github and version 1.1.0 of the client will be released today. https://github.com/basho/riak-java-client/pull/212 Thanks! Brian Roach On Thu, Feb 14, 2013 at 9:31 AM, Daniel Iwan wrote: > I see 100% CPU very regula

Re: riak java client causing OOMs on high latency [resolution]

We now believe this to be fixed in the following commit to rjc. Socket timeouts were not resulting in permits being released - https://github.com/basho/riak-java-client/commit/b8a4e7b872ae26e2c38e0ff4dd3e2d617a2c8344 The content of the byte[]s indicated that multiple threads were reading from the

Re: riak java client causing OOMs on high latency

The code you cite is reading a size (32 bit int, network byte order) and a message code (8bit int) from the socket. It then creates a byte[] of the size required for the amount of data that has been requested and then sent back by Riak to the client in a response. (See the docs here: http://docs.

Re: Riak JAVA Client Performance

Thanks. It is very useful information. Pavel On Sun, Oct 14, 2012 at 6:48 AM, Brian Roach wrote: > Some points about how the Java client works: > > You use a single instance of the client and share it across threads. > > The client holds a connection pool. It grows as necessary. You can > speci

Re: Riak JAVA Client Performance

Some points about how the Java client works: You use a single instance of the client and share it across threads. The client holds a connection pool. It grows as necessary. You can specify the starting size of the pool and the max size (default is unlimited). There is an idle reaper thread in tha

Re: Riak JAVA Client Performance

Hi Pavel, I'm not an expert with the pool size, but depending on your average key size and nodes you could tune it to your needs, regarding the client, a single shared client instance will suffice, there is a retrier parameter which says how many times Riak will retry your operation before

Re: Riak JAVA Client Performance

Thanks Guido, Pawel, I will try using HAProxy + holding N concurrent connections on the client side. I want clear for myself some point about concurrent connections: 1) What is reasonable limit of concurrent connections? 2) Concurrent connections = separate generated pbc clients or single shared p

Re: Riak JAVA Client Performance

From that perspective, for now it is better to treat the client as you would treat a JDBC DataSource pool, the tidy up comes when connecting the client, either one node or many, the client will behave better if it has no knowledge of whats going on at the cluster side, of course, that's as of 1

Re: Riak JAVA Client Performance

ok, you have 100% point here, on the other hand I think pavel looks for some guidance how to improve performance on client side, so he can be 100% sure he is not wasting time on something. this is maybe premature optimization but it maybe also good position to understand library and enter new world

Re: Riak JAVA Client Performance

In fact, as more nodes, you might be surprised it that it might be fastersee my point? Riak is a lot of things, 1st you have to be aware of the hashing, hashmap, how a key gets copied into different nodes, how one or more nodes are responsible for a key, etc...so it is not that simple. On

Re: Riak JAVA Client Performance

That's why I keep pushing to one answer, Riak is not meant to be in one cluster, you are removing the external factors and CAP settings you will be using, and it won't be linear, you could get the same results with RW=2 with 3, 4 and 5 nodes, there are several factors that will influence your b

Re: Riak JAVA Client Performance

I understand that load balancing is a final solution, but I want to benchmark single node. If I knew that I can load single node with N requests / sec, I could assume that after load balancing over 5 nodes my throughput limit will increase linearly. Pavel On Wed, Oct 10, 2012 at 2:51 PM, Guido Me

Re: Riak JAVA Client Performance

The answer is there, create a client config with N pooled connections to your load balancer whatever you are using, I know HA proxy supports the PBC config (TCP based) which is faster than HTTP client, and hence my recommendation. Say, a non-clustered client config with N connections to balanc

Re: Riak JAVA Client Performance

Hi, The node is OK and not down. I have a way to do load balancing externally to JAVA Client. I am evaluating Riak for using in my company and want to measure maximal throughput vs single node. Thanks, Pavel On Wed, Oct 10, 2012 at 2:13 PM, Guido Medina wrote: > That question has been answe

Re: Riak JAVA Client Performance

That question has been answered few times, here is my old answer: Hi, It is the Java client which to be honest, doesn't handle well one node going down, so, for example, in my company we use HA proxy for that, here is a starting configuration:https://gist.github.com/1507077 Once we switched

Re: Riak JAVA Client Performance

Thanks, I will try this solution. Pavel On Wed, Oct 10, 2012 at 1:51 PM, kamiseq wrote: > well I asked same question few days ago (maybe 2 weeks form now) and > the answer was that yes sharing client is thread safe and all you > should do is to create new bucket instance on every request > > p

Re: Riak JAVA Client Performance

well I asked same question few days ago (maybe 2 weeks form now) and the answer was that yes sharing client is thread safe and all you should do is to create new bucket instance on every request pozdrawiam Paweł Kamiński kami...@gmail.com pkaminski@gmail.com __ On 10 Oct

Re: Riak JAVA Client Performance

1) Is it ok to share a single pbc client object between 50 threads? Should it be protected by lock ? 2) I didn't do load balancing between nodes yet, cause I want to understand better throughput limit. I am planning to do it for much higher throughput. Pavel On Wed, Oct 10, 2012 at 9:21 AM, kamis

Re: Riak JAVA Client Performance

maybe the good start is to share pbclient object and only create bucket per request, you will save few steps on client configuration. have you tried balancing requests to cluster and distribute them over all nodes? pozdrawiam Paweł Kamiński kami...@gmail.com pkaminski@gmail.com __

Re: Riak java client - HTTP client...

The travis CI build fails occasionally with a map/reduce timeout issue that isn't due to the client (directly) that still needs addressing. It's nothing to worry about. On Tue, Oct 2, 2012 at 9:06 AM, Guido Medina wrote: > Hi, > > Is there any particular issue with the Java Riak HttpClient when

Re: Riak Java client questions

Hi Oved - replies inlined below. On Aug 2, 2012, at 11:04 AM, Oved Machlev wrote: > Hi, > > I have been working with Riak in past 3 weeks, using the java client. > I have encountered a few issues, and could not find solutions so far. > This is the first time I write an email to this mailing li

Re: Riak-java-client through a HTTP proxy

On 16 Dec 2011, at 09:13, Russell Brown wrote: > Hi, > On 16 Dec 2011, at 08:58, Olivier Rossel wrote: > >> … >> >> Is there a special way to declare proxies in riak-java-client ? > Yes. Can you let me know which version of the RJC you are using, please? OK, from speaking to you on another cha

Re: Riak-java-client through a HTTP proxy

Hi, On 16 Dec 2011, at 08:58, Olivier Rossel wrote: > [I hope I am posting on the correct list.] > > I am using riak-java-client behind a http proxy. > I have set the properties like this: > System.setProperty("http.proxyHost", "webcache.mydomain.com"); > System.setPropery("http.proxyPort", "8080

Re: riak java client

Thanks, riakObject.setContentType("application/json") work right. ___ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Re: riak java client

Ok, If I do curl -X PUT with -H "Content-Type: application/json;charset=utf-8" , it is work - index and search Riak right. I use Riak 1.0.1-1 (riak_1.0.1-1_amd64.deb on Ubuntu). And I use UTF-8 for java strings. ___ riak-users mailing list riak-users@l

Re: riak java client

On 17 Nov 2011, at 16:03, sergey wrote: > Ok, > If I do curl -X PUT -H "Content-Type: application/json;charset=utf-8", Riak > index for search and search work right. > I use Riak 1.0.1-1 (riak_1.0.1-1_amd64.deb on Ubuntu). > I use utf-8 java string. Yes. We have a bug. Sorry. https://issues.bas

Re: riak java client

Ok, If I do curl -X PUT -H "Content-Type: application/json;charset=utf-8", Riak index for search and search work right. I use Riak 1.0.1-1 (riak_1.0.1-1_amd64.deb on Ubuntu). I use utf-8 java string. ___ riak-users mailing list riak-users@lists.basho.

Re: riak java client

On 17 Nov 2011, at 10:20, sergey wrote: > Thanks Russell! > I use raw client: > > rawClient = new RiakClient("127.0.0.1") > pbcClient = new PBClientAdapter(rawClient) > riakObject = RiakObjectBuilder.newBuilder("users", > userName).withContentType("application/json").withValue(userInfo).build >

Re: riak java client

Thanks Russell! I use raw client: rawClient = new RiakClient("127.0.0.1") pbcClient = new PBClientAdapter(rawClient) riakObject = RiakObjectBuilder.newBuilder("users", userName).withContentType("application/json").withValue(userInfo).build pbcClient.store(riakObject) In store, Content Type app

Re: riak java client

On 16 Nov 2011, at 16:13, sergey wrote: > Thanks Russell, > ok, > I useDefaultRiakClient ( userName = "user1", userInfo = > "{"email":"em...@email.com","pass":"123123"}" ): > riakObject = RiakObjectBuilder.newBuilder("users", > userName).withContentType("application/json").withValue(userInfo).b

Re: riak java client

Thanks Russell, ok, I useDefaultRiakClient ( userName = "user1", userInfo = "{"email":"em...@email.com","pass":"123123"}" ): riakObject = RiakObjectBuilder.newBuilder("users", userName).withContentType("application/json").withValue(userInfo).build and store: client.fetchBucket("users").execute.

Re: riak java client

And too the list this time :$ Hi Sergey, On 16 Nov 2011, at 10:48, sergey wrote: > Hi! > How to set content type for store operation for java-pcb client? > b.store("key", "{"field":"value"}") - set content as text/plain, how set > content type as application/json? That is just a conveni

Re: Riak Java Client Error

Muhammad, I think the problem you're running into is that the value must be specified as a byte array. Try this: RiakObject o = new RiakObject("mybucket", "mykey", (new String("myvalue")).getBytes()); I think that should do it. Kelly On Wed, Mar 30, 2011 at 1:09 PM, Muhammad Yousaf wrot

RE: Riak Java Client Error

Hi Russel ,Thanks a lot for your help that was soo helpful. But unfortunately i got another error on creating object of riak object on following codeimport com.basho.riak.client.RiakClient;import com.basho.riak.client.RiakObject;import com.basho.riak.client.response.FetchResponse;public class

Re: Riak Java Client Error

Build Path > Problem > Unbound classpath variable: > 'M2_REPO/org/mockito/mockito-all/1.8.0/mockito-all-1.8.0.jar' in project > 'RiakClient' RiakClient Build path Build Path Problem > > can you please tell me how can i fix them ? >

RE: Riak Java Client Error

nt-0.14.0.jarcommons-codec-1.2.jar commons-httpclient-3.1.jarcommons-logging-1.0.4.jarprotobuf-java-2.3.0.jar Regards, Muhammad Yousaf Subject: Re: Riak Java Client Error From: russell.br...@me.com Date: Wed, 30 Mar 2011 14:13:49 +0100 CC: riak-users@lists.basho.com To: muhammad.you...@live.c

Re: Riak Java Client Error

Hi Muhammad, The riak java client depends on a couple of external libraries (eg. Apache commons HttpClient, google protobufs). These need to be on your class path when you run your program. The easiest way to do this is to use maven[1]. Using maven means you can simply declare the client as a de

Re: riak java client review (was Re: Riak Recap for March 14 - 15)

On 17 Mar 2011, at 13:57, Abhishek Kona wrote: > Yes. > Earlier query : > http://lists.basho.com/pipermail/riak-users_lists.basho.com/2011-March/003461.html Right, I remember now. At the moment I'm inclined toward leaving the job of load balancing to a load balancer (like haproxy.) I guess it

Re: riak java client review (was Re: Riak Recap for March 14 - 15)

On 17 Mar 2011, at 12:30, Jon Brisbin wrote: > > On Mar 16, 2011, at 6:39 PM, Mark Phillips wrote: > >> 3) Mark Wolfe put together some thoughtful observations about Riak and >> the Java Client. This is a great read. >> >> * Check them out here ---> >> https://github.com/wolfeidau/riak-log4j-a

Re: Riak Java Client

Excellent, I'll give that a shot. Thanks, On Sun, Feb 20, 2011 at 4:00 PM, Russell Brown wrote: > > When you store using RiakClient.store(RiakObject, RequestMeta) you can set up > RequestMeta with arbitrary query params like > >        RequestMeta requestMeta = RequestMeta.writeParams(3, > 3)

Re: Riak Java Client

Sorry to self-reply...I've been reading and have a short term answer to your 3rd point, please see inline below. However I do think it could be baked into the API more clearly. On 19 Feb 2011, at 18:29, Russell Brown wrote: > > On 18 Feb 2011, at 23:20, Wilson MacGyver wrote: > >> 3: suppor

Re: Riak Java Client

On 18 Feb 2011, at 23:20, Wilson MacGyver wrote: > We use the java client, mostly in groovy. In terms of wish list > > 1: Protocol buffer support, this is addressed in the 0.14 version. > > 2: make the httpconnection max client setting work. I couldn't get this to > work > no matter what I do.

Re: Riak Java Client

We use the java client, mostly in groovy. In terms of wish list 1: Protocol buffer support, this is addressed in the 0.14 version. 2: make the httpconnection max client setting work. I couldn't get this to work no matter what I do. It always only open 1 connection. 3: support no-data flag. I not

Re: Riak Java Client

On Tue, Feb 15, 2011 at 5:37 PM, Mark Wolfe wrote: > Gday > Been messing around on some personal projects which use riak with Java and > was interested to know if their was a roadmap or task list of the java > client. This is one of the things we're working on solidifying and would love to get fe

Re: riak java client 0.14 changelog?

Thanks, will give it a try ___ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Re: riak java client 0.14 changelog?

Hi Wilson, There is no official changelog available at the moment but you can get an idea of the changes by reviewing the commits and files changed between the versions: https://github.com/basho/riak-java-client/compare/riak-client-0.11.0...riak-client-0.14.0 It looks like protocol buffers was ad

Re: riak-java-client

I've just pushed a fix for this API oversight to the tip of the riak-java-client repository. You can pull and build source if you need the fix now or wait for the next release. Please feel free to report any problems you might encounter with this fix if you do decide to try it out. --Kevin On

Re: riak-java-client

Hi Simon, Just realized your question was specific to the Java client. I don't see a way to provide the "arg" property in the Java client. I've filed a bug for this issue: http://issues.basho.com/show_bug.cgi?id=257 Thanks, Dan Daniel Reverri Developer Advocate Basho Technologies, Inc. d...@bash

Re: riak-java-client

Hi Simon, Static arguments can be passed to MapReduce queries using the "arg" property. Here is an example query that runs over all the keys in the bucket "bucket": { "inputs": "bucket", "query": [ { "map": { "language": "javascript", "so