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