Completely separate 1.0.3 (note the version diff) installation, 3 new
nodes, bitcask backend (instead of leveldb), absolutely no data.
Rebuilt making sure I had latest erlang_protobuffs tag (0.6.0).
Fire up three nodes, build some connections, and repeat using binary-only.
3>
riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),get_connector_pid),
<<"alliance_overview">>).
{ok,[]}
4>
riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),get_connector_pid),
<<"alliance_overview">>).
{ok,[]}
5>
riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),get_connector_pid),
<<"alliance_overview">>).
=ERROR REPORT==== 21-Jan-2012::13:57:42 ===
** Generic server <0.1411.0> terminating
** Last message in was {tcp,#Port<0.5504>,[255|<<"unknown_msg">>]}
** When Server state == {state,"127.0.0.1",2030,false,false,#Port<0.5504>,
{request,#Ref<0.0.0.16491>,
{rpblistkeysreq,<<"alliance_overview">>},
undefined,
{120402956,<0.1168.0>},
60000,#Ref<0.0.0.16492>},
{[],[]},
1,[],infinity,100}
** Reason for termination ==
** {function_clause,[{riakclient_pb,decode,[undefined,<<"unknown_msg">>]},
{riakc_pb_socket,handle_info,2},
{gen_server,handle_msg,5},
{proc_lib,init_p_do_apply,3}]}
{error,{timeout,[]}}
6>
riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),get_connector_pid),
<<"alliance_overview">>).
{ok,[]}
Console again shows
===== Sat Jan 21 13:55:06 PST 2012
13:55:06.888 [info] Handoff receiver for partition undefined exited
after processing 0 objects
-mox
On Sat, Jan 21, 2012 at 10:24 AM, Mike Oxford <moxf...@gmail.com> wrote:
> Shouldn't matter in the end, but it does happen both ways. That
> version is just the snippet I happened to paste.
>
> -mox
>
> On Sat, Jan 21, 2012 at 9:33 AM, Basho <ke...@basho.com> wrote:
>> Not sure if it's the cause of the error, but I notice sometimes you're using
>> a string for the bucket name when it should always be passed as a binary.
>>
>> Kelly
>>
>> Sent from my iPhone
>>
>> On Jan 21, 2012, at 9:43 AM, Mike Oxford <moxf...@gmail.com> wrote:
>>
>>> 3 node cluster of 1.0.2, level_db backend, pb interface. Build up a
>>> store of 9 connections (3 to each node) and pull one out randomly.
>>>
>>> --snip
>>> 62>
>>> riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),
>>> get_connector_pid), <<"alliance_overview">>
>>> {ok,[]}
>>>
>>> 63>
>>> riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),
>>> get_connector_pid), <<"alliance_overview">>).
>>> {ok,[]}
>>>
>>> 64>
>>> riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),
>>> get_connector_pid), "alliance_overview").
>>> {ok,[]}
>>>
>>> 65>
>>> riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),
>>> get_connector_pid), "alliance_overview").
>>> =ERROR REPORT==== 21-Jan-2012::08:23:11 ===
>>> ** Generic server <0.24647.5> terminating
>>> ** Last message in was {tcp,#Port<0.5820>,[255|<<"unknown_msg">>]}
>>> ** When Server state == {state,"127.0.0.1",2010,false,false,#Port<0.5820>,
>>> {request,#Ref<0.0.4.159143>,
>>> {rpblistkeysreq,"alliance_overview"},
>>> undefined,
>>> {106931976,<0.25063.5>},
>>> 60000,#Ref<0.0.4.159144>},
>>> {[],[]},
>>> 1,[],infinity,100}
>>> ** Reason for termination ==
>>> ** {function_clause,[{riakclient_pb,decode,[undefined,<<"unknown_msg">>]},
>>> {riakc_pb_socket,handle_info,2},
>>> {gen_server,handle_msg,5},
>>> {proc_lib,init_p_do_apply,3}]}
>>> {error,{timeout,[]}}
>>>
>>> 66>
>>> riakc_pb_socket:list_keys(gen_server:call(forum_store:get_random_pid(alliance),
>>> get_connector_pid), "alliance_overview").
>>> {ok,[]}
>>> --end snip
>>>
>>> Riak console spits out the following at the same time...
>>>
>>> --snip
>>> nodes().08:23:11.154 [info] Handoff receiver for partition undefined
>>> exited after processing 0 objects
>>> --end snip
>>>
>>> Error condition does not seem to follow any specific node and the
>>> connections die when the error is thrown so its constantly building
>>> new ones.
>>>
>>> TIA.
>>>
>>> -mox
>>>
>>> _______________________________________________
>>> riak-users mailing list
>>> riak-users@lists.basho.com
>>> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
_______________________________________________
riak-users mailing list
riak-users@lists.basho.com
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
