odd error on mapreduce

Giancarlo Frison gfrison at chelab.com
Thu Aug 25 09:48:43 EDT 2011


Hi all,

I'm performing a mapreduce call for retrieving objects with a peculiar tag
link:

{"inputs": "minos","query": [{"map": {"language": "javascript","source":
"function(v){ if(v.values[0].metadata.Links!=null &&
v.values[0].metadata.Links[0][0]==\"eclass-com_chelab_core_minos\"
&&v.values[0].metadata.Links[0][1]==\"State\"
&&v.values[0].metadata.Links[0][2]==\"iof\")  {return [v.key]; } else return
[];}"}}]}

I have an object stored in binary format(protobuf) that the body is (json
format):

{
    "name": "2login",
    "type": "start",
    "transitions": [
        {
            "name": "logon",
            "nextState": "logged",
            "guard": "request.user!=null && request.password!=null",
            "activity": {
                "name": "call-login",
                "serviceName": "http://apigeoname",
                "condition": "this.password==request.password"
            }
        }
    ]
}

and the mapreduce works fine.

IF I change JUST 'serviceName' element to 'http://apigeonames' adding the
last char 's' I encounter and error in the mapreduce above.
the error log is:



Error JSON encoding arguments: [{struct,
                                 [{<<"bucket">>,<<"minos">>},
                                  {<<"key">>,<<"2login">>},
                                  {<<"vclock">>,

 <<"a85hYGBgzGDKBVIsLNdPbMpgSmTMY2XYIXvmOF8WAA==">>},
                                  {<<"values">>,
                                   [{struct,
                                     [{<<"metadata">>,
                                       {struct,
                                        [{<<"Links">>,

[[<<"eclass-com_chelab_core_minos">>,
                                            <<"State">>,<<"iof">>]]},
                                         {<<"X-Riak-VTag">>,
                                          <<"1uFeJm9wytHzl66Pxjsunx">>},
                                         {<<"content-type">>,
                                          <<"application/octet-stream">>},
                                         {<<"X-Riak-Last-Modified">>,
                                          <<"Fri, 26 Aug 2011 13:38:00
GMT">>}]}},
                                      {<<"data">>,
                                       <<26,128,1,10,5,108,111,103,111,
                                         110,18,6,108,111,103,103,101,
                                         100,26,44,114,101,113,117,101,
                                         115,116,46,117,115,101,114,33,
                                         61,110,117,108,108,32,38,38,32,
                                         114,101,113,117,101,115,116,46,
                                         112,97,115,115,119,111,114,100,
                                         33,61,110,117,108,108,34,65,18,
                                         18,104,116,116,112,58,47,47,97,
                                         112,105,103,101,111,110,97,109,
                                         101,115,34,10,99,97,108,108,45,
                                         108,111,103,105,110,42,31,116,
                                         104,105,115,46,112,97,115,115,
                                         119,111,114,100,61,61,114,101,
                                         113,117,101,115,116,46,112,97,
                                         115,115,119,111,114,100,42,6,

 50,108,111,103,105,110,64,6>>}]}]}]},
                                undefined,none]

{error,
    {no_candidate_nodes,exhausted_preflist,
        [{riak_kv_mapred_planner,claim_keys,3},
         {riak_kv_map_phase,handle_info,2},
         {luke_phase,handle_info,3},
         {gen_fsm,handle_msg,7},
         {proc_lib,init_p_do_apply,3}],
        [{{5680,'riak at 127.0.0.1'},
          [{pid,<0.12932.0>},
           {keys,
               {{730750818665451459101842416358141509827966271488,
                 'riak at 127.0.0.1'},
                [{riak_kv_map_input,
                     {<<"minos">>,<<"2login">>},
                     [{name,<<"minos">>},
                      {n_val,3},
                      {allow_mult,false},
                      {last_write_wins,false},
                      {precommit,[]},
                      {postcommit,[]},
                      {chash_keyfun,{riak_core_util,chash_std_keyfun}},
                      {linkfun,

{modfun,riak_kv_wm_link_walker,mapreduce_linkfun}},
                      {old_vclock,86400},
                      {young_vclock,20},
                      {big_vclock,50},
                      {small_vclock,10},
                      {r,quorum},
                      {w,quorum},
                      {dw,quorum},
                      {rw,quorum}],
                     undefined,
                     [{730750818665451459101842416358141509827966271488,
                       'riak at 127.0.0.1'}]}]}}]},
         {<0.12932.0>,{5680,'riak at 127.0.0.1'}}]}}


have you any idea about this problem?

Thanks,


Giancarlo Frison
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.basho.com/pipermail/riak-users_lists.basho.com/attachments/20110825/80e03117/attachment.html>


More information about the riak-users mailing list