MR error - How to make sense of error message in riak

David Montgomery davidmontgomery at gmail.com
Thu Jul 18 18:49:01 EDT 2013


Hi,

I am trying to run a MR script;

WHat does the below error translate into in in english?

Traceback (most recent call last):
  File
"/home/ubuntu/workspace/ndkt-scraper/src/parsers/archive/riak_mapreduce_archive.py",
line 188, in <module>
    bucket = 'archive_temp'
  File
"/home/ubuntu/workspace/ndkt-scraper/src/parsers/archive/riak_mapreduce_archive.py",
line 162, in getCountOfRecords
    print 'starting MR............'
  File
"/usr/local/lib/python2.7/dist-packages/riak-1.5.2-py2.7.egg/riak/mapreduce.py",
line 234, in run
    result = t.mapred(self._inputs, query, timeout)
  File
"/usr/local/lib/python2.7/dist-packages/riak-1.5.2-py2.7.egg/riak/transports/pbc.py",
line 454, in mapred
    _handle_response)
  File
"/usr/local/lib/python2.7/dist-packages/riak-1.5.2-py2.7.egg/riak/transports/pbc.py",
line 548, in send_msg_multi
    msg_code, resp = self.recv_msg(conn, expect)
  File
"/usr/local/lib/python2.7/dist-packages/riak-1.5.2-py2.7.egg/riak/transports/pbc.py",
line 589, in recv_msg
    raise Exception(msg.errmsg)
Exception:
{"phase":0,"error":"{noproc,{gen_server,call,[riak_kv_js_map,{reserve_vm,<0.16749.503>},infinity]}}","input":"{ok,{r_object,<<\"archive_temp\">>,<<\"
archive.org/download/gov.uscourts.cod.99487/gov.uscourts.cod.99487.docket.html\
">>,[{r_content,{dict,4,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[],[],[],[],[],[],[],[],[[<<\"content-type\">>,97,112,112,108,105,99,97,116,105,111,110,47,106,115,111,110],[<<\"X-Riak-VTag\">>,55,52,51,108,49,120,100,116,50,76,106,99,98,109,73,84,119,54,107,69,112,118]],[[<<\"index\">>]],[],[[<<\"X-Riak-Last-Modified\">>|{1372,743179,489612}]],[],[]}}},<<\"{...\">>}],...},...}","type":"exit","stack":"[{gen_server,call,3,[{file,\"gen_server.erl\"},{line,188}]},{riak_kv_js_manager,blocking_dispatch,4,[{file,\"src/riak_kv_js_manager.erl\"},{line,245}]},{riak_kv_mrc_map,map_js,3,[{file,\"src/riak_kv_mrc_map.erl\"},{line,192}]},{riak_kv_mrc_map,process,3,[{file,\"src/riak_kv_mrc_map.erl\"},{line,140}]},{riak_pipe_vnode_worker,process_input,3,[{file,\"src/riak_pipe_vnode_worker.erl\"},{line,444}]},{riak_pipe_vnode_worker,wait_for_input,2,[{file,\"src/riak_pipe_vnode_worker.erl\"},{line,376}]},{gen_fsm,handle_msg,...},...]"}



below is my mapper


function(value, keyData, arg) {

        if(value.length == 0){
           return [];
        }else{
            var data = Riak.mapValuesJson(value)[0];
            var obj = {};

            if(data.hasOwnProperty('case_details')){
                try {
                    var alt_key = 1;
                }
                catch(err){
                      var alt_key = 'error';
                }
                obj[alt_key] = 1;
                return [ obj ];
            }
            else{
               return [];
            }
        }
    }'''
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.basho.com/pipermail/riak-users_lists.basho.com/attachments/20130719/ff9c3c24/attachment.html>


More information about the riak-users mailing list