diff --git a/apps/emqx_modules/src/emqx_topic_metrics_api.erl b/apps/emqx_modules/src/emqx_topic_metrics_api.erl index 1ba76579b..251cf4d81 100644 --- a/apps/emqx_modules/src/emqx_topic_metrics_api.erl +++ b/apps/emqx_modules/src/emqx_topic_metrics_api.erl @@ -235,7 +235,7 @@ accumulate_metrics(TopicMetricsIn, TopicMetricsAcc) -> %% @doc MetricsIn :: #{'messages.dropped.rate' :: integer(), ...} do_accumulation_metrics(MetricsIn, undefined) -> MetricsIn; -do_accumulation_metrics(MetricsIn, MetricsAcc) -> +do_accumulation_metrics(MetricsIn, {MetricsAcc, _}) -> Keys = maps:keys(MetricsIn), lists:foldl(fun(Key, Acc) -> InVal = maps:get(Key, MetricsIn),