yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: case_clause

This commit is contained in:
zmstone 2024-03-25 16:42:46 +01:00
parent c93145cb97
commit d38545010a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx/src/emqx_router.erl
View File

@ -747,14 +747,14 @@ choose_schema_vsn(ConfSchema, ClusterSchema, State) ->
[Schema] when ClusterSchema =:= undefined -> [Schema] when ClusterSchema =:= undefined ->
%% There are existing records following some schema, we have to use it. %% There are existing records following some schema, we have to use it.
Schema; Schema;
[v1, v2] when ClusterSchema =/= undefined -> _Conflicting when ClusterSchema =/= undefined ->
%% There are existing records in both v1 and v2 schema, %% There are existing records in both v1 and v2 schema,
%% we have to use what the peer nodes agreed on. %% we have to use what the peer nodes agreed on.
%% because it could be HTIS node which caused cnoflict. %% because it could be HTIS node which caused cnoflict.
%% %%
%% The stale records will be left-over, but harmless %% The stale records will be left-over, but harmless
ClusterSchema; ClusterSchema;
[v1, v2] -> _Conflicting ->
Desc = schema_conflict_reason(records, State), Desc = schema_conflict_reason(records, State),
io:format(standard_error, "Error: ~ts~n", [Desc]), io:format(standard_error, "Error: ~ts~n", [Desc]),
?SLOG(critical, #{ ?SLOG(critical, #{