Hello list,

I am using Riak 2.0.0rc1 and nlf’s riakpbc <https://github.com/nlf/riakpbc/> 
client. While performing a map reduce operation with the request input: inputs: 
['test1', 'mapred_test’] where ‘test1’ is the bucket type and executing the 
‘Riak.mapValuesJson’ function, I am getting the following error:

{ [Error: Error processing stream message: 
exit:{ucs,{bad_utf8_character_code}}:[{xmerl_ucs,
                                                                        
from_utf8,
                                                                        1,
                                                                        [{file,
                                                                          
"xmerl_ucs.erl"},
                                                                         {line,
                                                                          
185}]},
                                                                       
{mochijson2,
                                                                        
json_encode_string,
                                                                        2,
                                                                        [{file,
                                                                          
"src/mochijson2.erl"},
                                                                         {line,
                                                                          
186}]},
                                                                       
{mochijson2,
                                                                        
'-json_encode_proplist/2-fun-0-',
                                                                        3,
                                                                        [{file,
                                                                          
"src/mochijson2.erl"},
                                                                         {line,
                                                                          
167}]},
                                                                       {lists,
                                                                        foldl,
                                                                        3,
                                                                        [{file,
                                                                          
"lists.erl"},
                                                                         {line,
                                                                          
1248}]},
                                                                       
{mochijson2,
                                                                        
json_encode_proplist,
                                                                        2,
                                                                        [{file,
                                                                          
"src/mochijson2.erl"},
                                                                         {line,
                                                                          
170}]},
                                                                       
{riak_kv_pb_mapred,
                                                                        
process_stream,
                                                                        3,
                                                                        [{file,
                                                                          
"src/riak_kv_pb_mapred.erl"},
                                                                         {line,
                                                                          
142}]},
                                                                       
{riak_api_pb_server,
                                                                        
process_stream,
                                                                        5,
                                                                        [{file,
                                                                          
"src/riak_api_pb_server.erl"},
                                                                         {line,
                                                                          
411}]},
                                                                       
{riak_api_pb_server,
                                                                        
handle_info,
                                                                        3,
                                                                        [{file,
                                                                          
"src/riak_api_pb_server.erl"},
                                                                         {line,
                                                                          
319}]}]] code: 0 }

Other operations like listing keys and contents work fine. For example, the 
value of key '44dd14d4-8d53-460d-8e64-258d375d65fc’ (uuid4) is: 
{ context: <Buffer 83 6c 00 00 00 01 68 02 6d 00 00 00 08 23 09 fe f9 53 ea 22 
e3 61 01 6a>,
  type: 3,
  value: 
   { map_value: 
      [ { field: { name: 'volume', type: 3 },
          register_value: '2325100' },
        { field: { name: 'open', type: 3 }, register_value: '514.43' },
        { field: { name: 'low', type: 3 }, register_value: '511.40' },
        { field: { name: 'high', type: 3 }, register_value: '517.45' },
        { field: { name: 'date', type: 3 },
          register_value: '2007-08-27' },
        { field: { name: 'close', type: 3 }, register_value: '513.26' },
        { field: { name: 'adjusted close', type: 3 },
          register_value: '513.26' } ] } }

The code for the nodejs script and python script for populating the db: 
https://gist.github.com/singhkushagra/92c18f8ca2ba73976127 
<https://gist.github.com/singhkushagra/92c18f8ca2ba73976127>

Any help ?

cheers,
Kushagra Singh

_______________________________________________
riak-users mailing list
riak-users@lists.basho.com
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Reply via email to