One issue that immediately stands out:
> >>>
> Bucket bucket = sharedClient.createBucket("accounts1").execute();
> bucket.store(a.getId().toString(),
mapper.writeValueAsString(a)).execute();
> >>>
'CreateBucket()' is doing a fetch of the bucket properties and then storing
them back to the cluster when 'execute()' is called.
You want to fetch the bucket once then pass around the reference to it, or
at the very least use:
fetchBucket("accounts1").lazyLoadBucketProperties().execute();
Inside your threads.
The only time you ever want to use createBucket() is when you want to
modify the bucket properties.
- Roach
_______________________________________________
riak-users mailing list
riak-users@lists.basho.com
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
