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 [];
}
}
}'''
_______________________________________________
riak-users mailing list
[email protected]
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
