Pass keyarg from one map phase to another?

2012-03-23 Thread Matthew A. Brown
For situations in which one map phase passes output to a subsequent map phase, the documentation states: These map functions filter their inputs based on the arg and return bucket-key pairs for a subsequent map phase Is it possible to also return a keyarg? So a three-element array? Thanks! M

"forward_preflist" timeout error after 1.1 upgrade

2012-02-22 Thread Matthew A. Brown
Hi all, We're seeing a new timeout error after upgrading our cluster to Riak 1.1. The error message: {"phase":0,"error":"[timeout]","input":"{{<<\"service_profiles\">>,<<\"8fh/2\">>},{struct,[{<<\"key\">>,<<\"s-10925\">>}]}}","type":"forward_preflist","stack":"[]"} Sean indicates that the "forwa

Re: error: undef done()

2012-02-01 Thread Matthew A. Brown
Hey Bryan, That's awesome -- with the Riak 1.1 output figuring out the problem would've been a snap. Thanks! Mat On Wed, Feb 1, 2012 at 13:36, Bryan Fink wrote: > On Wed, Feb 1, 2012 at 11:43 AM, Matthew A. Brown > wrote: >> Thanks much for the info. We're running

Re: error: undef done()

2012-02-01 Thread Matthew A. Brown
call trace, which appears after the dump of the inputs. It was pretty easy to track down once I narrowed down the inputs to a manageable size that still reproduced the error. Thanks! Mat On Wed, Feb 1, 2012 at 10:53, Bryan Fink wrote: > On Tue, Jan 31, 2012 at 1:46 PM, Matthew A. Brown >

Re: error: undef done()

2012-01-31 Thread Matthew A. Brown
Scratch that -- I tracked it down to an actual call to an undefined function, which was not called "done()" -- I guess we can attribute this to Erlang's rather inscrutable error messages. On Tue, Jan 31, 2012 at 13:46, Matthew A. Brown wrote: > Hi all, > > I'm seein

error: undef done()

2012-01-31 Thread Matthew A. Brown
Hi all, I'm seeing a strange error raised from an Erlang reduce phase. This happens consistently with a certain set of inputs but I can't find any difference between those inputs and myriad other sets of inputs that produce no error. The error is simply: [error] error:undef done() The error mess

Re: Timeout during reduce phase

2011-12-13 Thread Matthew A. Brown
Hi Bryan, That sounds like the problem. Thanks, Mat On Tue, Dec 13, 2011 at 07:30, Bryan Fink wrote: > On Mon, Dec 12, 2011 at 1:12 PM, Matthew A. Brown > wrote: >> The map/reduce itself has a timeout of 10 minutes, but this is >> happening after about 30 seconds. Any

Re: Timeout during reduce phase

2011-12-12 Thread Matthew A. Brown
're using milliseconds[1] to specify the timeout? > > [1]: http://wiki.basho.com/MapReduce.html#HTTP-Query-Syntax > > Reid > > On Mon, Dec 12, 2011 at 1:12 PM, Matthew A. Brown > wrote: >> >> I'm running a map/reduce operation with fairly complex map and red

Timeout during reduce phase

2011-12-12 Thread Matthew A. Brown
I'm running a map/reduce operation with fairly complex map and reduce phases against about 2000 keys. Each key also has a (fairly small) payload arg. Currently just testing it locally against a single Riak node. I've started consistently seeing this error during the reduce phase: error:{case_claus