Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
I get this error when I increase the number of threads accessing a single connection. Something related to getting unexpected number of bytes on the connection. On Wednesday, June 27, 2012, Reid Draper wrote: > > On Jun 27, 2012, at 8:41 AM, Yousuf Fauzan wrote: > > So I created an array of clien

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Reid Draper
On Jun 27, 2012, at 8:41 AM, Yousuf Fauzan wrote: > So I created an array of clients using the following code > > Clients = [riak.RiakClient(e, port=8087, > transport_class=riak.RiakPbcTransport) for e in NODES] Sounds like you're bringing your concurrency back down to 3 (because you have thr

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
So I created an array of clients using the following code Clients = [riak.RiakClient(e, port=8087, transport_class=riak.RiakPbcTransport) for e in NODES] After this I assigned each thread a particular id ranging from 0 to Number of Nodes So each thread now communicates with a single node. Even

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
Oh! I think that may be an issue with my code then. Let me make some changes and get back to you. On Wed, Jun 27, 2012 at 5:25 PM, Reid Draper wrote: > > On Jun 27, 2012, at 7:48 AM, Yousuf Fauzan wrote: > > This is great. > > I was loading data using Python. My code would spawn 10 threads and

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Reid Draper
On Jun 27, 2012, at 7:48 AM, Yousuf Fauzan wrote: > This is great. > > I was loading data using Python. My code would spawn 10 threads and put data > in a queue. All threads would read data from this queue. > However, all threads were hitting the same server/load balancer. > > I tried a differ

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
This is great. I was loading data using Python. My code would spawn 10 threads and put data in a queue. All threads would read data from this queue. However, all threads were hitting the same server/load balancer. I tried a different setup too. Where I spawned processes with each process having i

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Russell Brown
On 27 Jun 2012, at 12:36, Yousuf Fauzan wrote: > So I changed concurrency to 10 and put all the IPs of the nodes in basho > bench config. > Throughput is now around 1500. > I guess you can now try 5 or 15 concurrent workers and see which is optimal for that set up to get a good feel for the s

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
So I changed concurrency to 10 and put all the IPs of the nodes in basho bench config. Throughput is now around 1500. On Wed, Jun 27, 2012 at 4:40 PM, Russell Brown wrote: > > On 27 Jun 2012, at 12:09, Yousuf Fauzan wrote: > > I used examples/riakc_pb.config > > {mode, max}. > > {duration, 10}.

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Russell Brown
On 27 Jun 2012, at 12:09, Yousuf Fauzan wrote: > I used examples/riakc_pb.config > > {mode, max}. > > {duration, 10}. > > {concurrent, 1}. Try upping this. On my local 3 node cluster with 8gb ram and an old, cheap quad core per box I'd set concurrency to 10 workers. > > {driver, basho_benc

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
I used examples/riakc_pb.config {mode, max}. {duration, 10}. {concurrent, 1}. {driver, basho_bench_driver_riakc_pb}. {key_generator, {int_to_bin, {uniform_int, 1}}}. {value_generator, {fixed_bin, 1}}. {riakc_pb_ips, [{}]}. {riakc_pb_replies, 1}. {operations, [{get, 1}, {update, 1}]

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Russell Brown
On 27 Jun 2012, at 12:05, Yousuf Fauzan wrote: > I did use basho bench on my clusters. It should throughput of around 150 Could you share the config you used, please? > > On Wed, Jun 27, 2012 at 4:24 PM, Russell Brown wrote: > > On 27 Jun 2012, at 11:50, Yousuf Fauzan wrote: > >> Its not ab

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
I did use basho bench on my clusters. It should throughput of around 150 On Wed, Jun 27, 2012 at 4:24 PM, Russell Brown wrote: > > On 27 Jun 2012, at 11:50, Yousuf Fauzan wrote: > > Its not about the difference in throughput in the two approaches I took. > Rather, the issue is that even 200 write

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Russell Brown
On 27 Jun 2012, at 11:50, Yousuf Fauzan wrote: > Its not about the difference in throughput in the two approaches I took. > Rather, the issue is that even 200 writes/sec is a bit on the lower side. > I could be doing something wrong with the configuration because people are > reporting throughp

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
Its not about the difference in throughput in the two approaches I took. Rather, the issue is that even 200 writes/sec is a bit on the lower side. I could be doing something wrong with the configuration because people are reporting throughputs of 2-3k ops/sec If anyone here could guide me in setti

Re: Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Eric Anderson
On Jun 27, 2012, at 5:13 AM, Yousuf Fauzan wrote: > Hi, > > I setup a 3 machine riak SM cluster. Each machine used 4GB Ram and riak > OpenSource SmartMachine Image. > > Afterwards I tried loading data by following two methods > 1. Bash script > #!/bin/bash > echo $(date) > for (( c=1; c<=1000;

Throughput issue contd. On Joyend Riak Smartmachine

2012-06-27 Thread Yousuf Fauzan
Hi, I setup a 3 machine riak SM cluster. Each machine used 4GB Ram and riak OpenSource SmartMachine Image. Afterwards I tried loading data by following two methods 1. Bash script #!/bin/bash echo $(date) for (( c=1; c<=1000; c++ )) do curl -s -d 'this is a test' -H "Content-Type: text/plain" http