From 1f718fbb94a97f657c3dae9da54994bb457b148a Mon Sep 17 00:00:00 2001 From: lafirest Date: Mon, 24 Jan 2022 18:16:29 +0800 Subject: [PATCH] fix(emqx_slow_subs): fix index update error --- apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl b/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl index c2bbc0e6d..f276d7ba0 100644 --- a/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl +++ b/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl @@ -262,7 +262,7 @@ try_insert_to_topk(MaxSize, Now, LastUpdateValue, TimeSpan, Id) -> -spec find_last_update_value(id()) -> non_neg_integer(). find_last_update_value(Id) -> case ets:next(?INDEX_TAB, ?INDEX(0, Id)) of - #index_tab{index = ?INDEX(LastUpdateValue, Id)} -> + ?INDEX(LastUpdateValue, Id) -> LastUpdateValue; _ -> 0