<html><body><div style="color:#000; background-color:#fff; font-family:times new roman, new york, times, serif;font-size:12pt"><div><span>Hello Riak folks,</span></div><div style="color: rgb(0, 0, 0); font-size: 16px; font-family: times new roman,new york,times,serif; background-color: transparent; font-style: normal;"><br><span></span></div><div style="color: rgb(0, 0, 0); font-size: 16px; font-family: times new roman,new york,times,serif; background-color: transparent; font-style: normal;"><span>We have a 3-node riak cluster on my local box with haproxy load balancer running on port 9190 for the riak cluster. I've attached the haproxy conf file for your reference.<br></span></div><div style="color: rgb(0, 0, 0); font-size: 16px; font-family: times new roman,new york,times,serif; background-color: transparent; font-style: normal;"><span><br class="yui-cursor"></span></div><div>We use riak-python-client to connect to Riak. While connecting through the
 HTTP interface, the riak client works fine. When I try to connect through the Protocol Buffer Interface, it throws exception.<br><br>Here's an excerpt from the code:<br><span style="font-style: italic;">    def get(self, keys):</span><br style="font-style: italic;"><span style="font-style: italic;">        #client = riak.RiakClient()</span><br style="font-style: italic;"><span style="font-style: italic;">        client = riak.RiakClient(port=9190, transport_class=riak.RiakPbcTransport)</span><br style="font-style: italic;"><span style="font-style: italic;">        bucket = client.bucket('test1')</span><br style="font-style: italic;"><span style="font-style: italic;">        ret = {}</span><br style="font-style: italic;"><span style="font-style: italic;">       
 try:</span><br style="font-style: italic;"><span style="font-style: italic;">            for key in keys:        </span><br style="font-style: italic;"><span style="font-style: italic;">                post = bucket.get(key)</span><br style="font-style: italic;"><span style="font-style: italic;">                ret[key] = post.get_data()</span><br style="font-style: italic;"><span style="font-style: italic;">            return ret</span><br style="font-style: italic;"><span style="font-style: italic;">        except Exception, e:</span><br style="font-style: italic;"><span style="font-style:
 italic;">            print  traceback.format_exc()</span><br style="font-style: italic;"><span style="font-style: italic;">            return False</span><span><br><br></span>and here's the stack trace.<br><span style="font-style: italic;">Traceback (most recent call last):</span><br style="font-style: italic;"><span style="font-style: italic;">  File "/home/ishwar/workspace/TestRiak/src/HelloWorld.py", line 22, in get</span><br style="font-style: italic;"><span style="font-style: italic;">    post = bucket.get(key)</span><br style="font-style: italic;"><span style="font-style: italic;">  File "/usr/local/lib/python2.6/dist-packages/riak-1.2.1-py2.6.egg/riak/bucket.py", line 245, in get</span><br style="font-style: italic;"><span style="font-style: italic;">    return obj.reload(r)</span><br
 style="font-style: italic;"><span style="font-style: italic;">  File "/usr/local/lib/python2.6/dist-packages/riak-1.2.1-py2.6.egg/riak/riak_object.py", line 290, in reload</span><br style="font-style: italic;"><span style="font-style: italic;">    Result = t.get(self, r, vtag)</span><br style="font-style: italic;"><span style="font-style: italic;">  File "/usr/local/lib/python2.6/dist-packages/riak-1.2.1-py2.6.egg/riak/transports/pbc.py", line 157, in get</span><br style="font-style: italic;"><span style="font-style: italic;">    msg_code, resp = self.recv_msg()</span><br style="font-style: italic;"><span style="font-style: italic;">  File "/usr/local/lib/python2.6/dist-packages/riak-1.2.1-py2.6.egg/riak/transports/pbc.py", line 349, in recv_msg</span><br style="font-style: italic;"><span style="font-style: italic;">    self.recv_pkt()</span><br style="font-style: italic;"><span
 style="font-style: italic;">  File "/usr/local/lib/python2.6/dist-packages/riak-1.2.1-py2.6.egg/riak/transports/pbc.py", line 401, in recv_pkt</span><br style="font-style: italic;"><span style="font-style: italic;">    format(len(self._inbuf), self._inbuf_len))</span><br style="font-style: italic;"><span style="font-style: italic;">RiakError: 'Socket returned short packet 135 - expected 1213486160'</span><br><br>Is this a problem with my haproxy config file or is there something wrong with riak settings? I'd be glad to share the output of logs if needed.<br>--<br>Thanks for the help.<br></div><div>Ishwar<br><br></div><div>Just another resurrected Neozoic Archosaur comics.<br>http://www.flickr.com/photos/mojosaurus/sets/72157600257724083/</div></div></body></html>