anchor.diff:  check_cluster_state_2(Node, Pid, Ref) ->
       Level = case rpc:call(Node, ?MODULE, get_node_stats, [], ?REQ_TIMEOUT) of
                   {ok, #state{compaction = CompactionState,
  -                            mq   = MQState,
                               cpu  = CPUState,
                               disk = DiskState}} ->
  -                    Level_1 = level_mq(MQState),
  -                    Level_2 = level_compaction(CompactionState),
  -                    Level_3 = level_cpu(CPUState),
  -                    Level_4 = level_disk(DiskState),
  -                    (Level_1 + erlang:round((Level_2 + Level_3 + Level_4) / 3));
  +                    Level_1 = level_compaction(CompactionState),
  +                    Level_2 = level_cpu(CPUState),
  +                    Level_3 = level_disk(DiskState),
  +                    lists:max([Level_1, Level_2, Level_3]);
                   _ ->
                       0
               end,
  
positive.code:              {ok, #state{}} | {error, Cause} when Cause::any()).
  get_node_stats() ->
      CompactionState = get_node_stats_1(compaction),
      MQState   = get_node_stats_1(mq),
      CPUState  = get_node_stats_1(cpu),
      DiskState = get_node_stats_1(disk),
      {ok, #state{compaction = CompactionState,
                  mq   = MQState,
                  cpu  = CPUState,
                  disk = DiskState
                 }}.
  
negative.code:     case leo_compact_fsm_controller:state() of
          {ok, #compaction_stats{} = State} ->
              lists:zip(record_info(fields, compaction_stats), tl(tuple_to_list(State)));
          _ ->
              []
      end;
  