我正在尝试在运行时升级 riak_core erlang 应用程序。
简单的升级正在起作用。我使用 rebar3 和 relflow 成功升级了应用程序。但是,如果我更改 vnode 的内部结构并使用 relflow 和 rebar3 relup 生成新版本,则 vnode 将停止工作。vnode 被称为“cavv”。
热升级后,此时崩溃:
DocIdx = riak_core_util:chash_key({<<"run">>, term_to_binary(os:timestamp())}),
导致此错误:
** exception error: bad argument
in function lists:keyfind/3
called as lists:keyfind(chash_keyfun,1,[{name,<<"run">>}|undefined])
in call from riak_core_util:chash_key/2 (_build/default/lib/riak_core/src/riak_core_util.erl, line 266)
in call from cavv_vnode:run/0 (_build/prod/lib/cavv/src/cavv_vnode.erl, line 38)
我的 relup 看起来像这样:
{"0.1.2",
[{"0.1.1",[],
[{load_object_code,{cavv,"20161203-211601-relflow",[cavv_vnode]}},
point_of_no_return,
{load,{cavv_vnode,brutal_purge,brutal_purge}}]}],
[{"0.1.1",[],[point_of_no_return]}]}.
我错过了什么吗?我是否必须重新启动一些主 vnode?我尝试重新启动一些主管,但没有成功。
查看riak_core的源代码:
%% @spec chash_key(BKey :: riak_object:bkey()) -> chash:index()
%% @doc Create a binary used for determining replica placement.
chash_key({Bucket,_Key}=BKey) ->
BucketProps = riak_core_bucket:get_bucket(Bucket),
chash_key(BKey, BucketProps).
%% @spec chash_key(BKey :: riak_object:bkey(), [{atom(), any()}]) ->
%% chash:index()
%% @doc Create a binary used for determining replica placement.
chash_key({Bucket,Key}, BucketProps) ->
{_, {M, F}} = lists:keyfind(chash_keyfun, 1, BucketProps), %% <-- Line 266
M:F({Bucket,Key}).
我试图了解发生了什么,但很难掌握正在发生的事情。BucketProps 中的某些内容是未定义的,升级后不应未定义什么?
当我重新启动整个应用程序时,它就像一个魅力。
我在使用 riak_core 进行热升级时是否遗漏了什么?还是关闭整个节点,然后升级并重新启动它,忘记热代码升级更好?
更新 与此同时,我发现 riak_core_bucket 出了点问题。
运行以下:riak_core_bucket:get_bucket(<<"run">>).
升级前:
[{name,<<"run">>},
{allow_mult,false},
{basic_quorum,false},
{big_vclock,50},
{chash_keyfun,{riak_core_util,chash_std_keyfun}},
{dvv_enabled,false},
{dw,quorum},
{last_write_wins,false},
{linkfun,{modfun,riak_kv_wm_link_walker,mapreduce_linkfun}},
{n_val,3},
{notfound_ok,true},
{old_vclock,86400},
{postcommit,[]},
{pr,0},
{precommit,[]},
{pw,0},
{r,quorum},
{rw,quorum},
{small_vclock,50},
{w,quorum},
{young_vclock,20}]
升级后:
[{name,<<"run">>}|undefined]
app_helper:get_env(riak_core, default_bucket_props).
升级后返回未定义。
我发现它会在升级过程中尝试处理 sys.config:
Warning: "_build/prod/rel/cavv/releases/0.1.2/sys.config" missing (optional)
使用生成的 app.conf 是不够的,因为它不包含之前显示的所有配置值。使用它只输出:[{n_val,3}]
.
也许墨鱼没有正确重新加载 conf 文件?
更新2
做了一些更多的挖掘。升级后application:get_all_env(riak_core).
返回不同的值。有任何想法吗?