Hi,
I am storing JSON data in riak in formate shown below:
{
'event_name' : 'add_to_cart',
'app_id' : 245
'device_id' : ggre11
}
Map reduce I ran:
+++++++++++++++++++++++++++++++++++
import riakclient = riak.RiakClient()query =
client.add('data')query.map("function(v) { var data =
JSON.parse(v.values[0].data); if(data.app_id == 245) { return [[v.key,
data]]; } return []; }")for result in query.run():
*print *result
++++++++++++++++++++++++++++++++++++++++++
Above code does not result into any output and getting error shown below:
riak.RiakError: 'Error running MapReduce operation. Headers:
<httplib.HTTPMessage instance at 0x7f893346eea8> Body:
\'{"phase":0,"error":"{{timeout,{gen_server,call,[<13322.456.0>,{checkout_to,<13322.9238.26>},1000]}},{gen_server,call,[riak_kv_js_map,{reserve_vm,<13322.22407.26>},infinity]}}","input":"{ok,{r_object,<<\\\\"data\\\\">>,<<\\\\"1UhtcNM7ycm5zbHn0ulq0ELPFFt\\\\">>,[{r_content,{dict,6,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[[<<\\\\"Links\\\\">>]],[],[],[],[],[],[],[],[[<<\\\\"content-type\\\\">>,97,112,112,108,105,99,97,116,105,111,110,47,106,115,111,110],[<<\\\\"X-Riak-VTag\\\\">>,55,88,115,111,98,76,88,112,97,77,56,101,80,111,69,90,81,55,77,78,67,49]],[[<<\\\\"index\\\\">>]],[],[[<<\\\\"X-Riak-Last-Modified\\\\">>|{1414,659851,836816}]],[],[[<<\\\\"X-Riak-Meta\\\\">>]]}}},<<\\\\"{\\\\\\\\\\\\"goal_short_name\\\\\\\\\\\\":
\\\\\\\\\\\\"zipcheck\\\\\\\\\\\\",
\\\\\\\\\\\\"...\\\\">>}],...},...}","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,242}]},{riak_kv_mrc_map,map_js,3,[{file,\\\\"src/riak_kv_mrc_map.erl\\\\"},{line,196}]},{riak_kv_mrc_map,process,3,[{file,\\\\"src/riak_kv_mrc_map.erl\\\\"},{line,144}]},{riak_pipe_vnode_worker,process_input,3,[{file,\\\\"src/riak_pipe_vnode_worker.erl\\\\"},{line,446}]},{riak_pipe_vnode_worker,wait_for_input,2,[{file,\\\\"src/riak_pipe_vnode_worker.erl\\\\"},{line,378}]},{gen_fsm,handle_msg,...},...]"}\''
Setup:
2 Machines with 8 GB RAM each, 5 Nodes on each machine and total 20GB
of data with replication factor of 3
Regards,
Dinesh
_______________________________________________
riak-users mailing list
[email protected]
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
