fix core in compaction diagnose
This commit is contained in:
		@ -855,8 +855,6 @@ int ObCompactionDiagnoseMgr::diagnose_tenant_tablet()
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    ObLSID ls_id;
 | 
			
		||||
    ObLSHandle ls_handle;
 | 
			
		||||
    ObLS *ls = nullptr;
 | 
			
		||||
    ObLSCheckStatus ls_check_status;
 | 
			
		||||
    bool tenant_major_finish = true;
 | 
			
		||||
    bool tablet_major_finish = true;
 | 
			
		||||
@ -875,7 +873,7 @@ int ObCompactionDiagnoseMgr::diagnose_tenant_tablet()
 | 
			
		||||
          } else if (OB_FAIL(ls_status_map_.set_refactored(ls_id, ls_check_status))) {
 | 
			
		||||
            LOG_WARN("failed to set ls check status", K(ret), K(ls_id), K(ls_check_status));
 | 
			
		||||
          } else if (!ls_check_status.need_merge_) {
 | 
			
		||||
            (void)abnormal_ls_id.push_back(ls->get_ls_id());
 | 
			
		||||
            (void)abnormal_ls_id.push_back(ls_id);
 | 
			
		||||
          }
 | 
			
		||||
        } else {
 | 
			
		||||
          LOG_WARN("failed to get ls check status from map", K(ret));
 | 
			
		||||
 | 
			
		||||
@ -536,13 +536,13 @@ private:
 | 
			
		||||
      int64_t tenant_id = MTL_ID();                                                                     \
 | 
			
		||||
      int64_t hash_value = ObScheduleSuspectInfo::gen_hash(tenant_id, dag_hash.inner_hash());          \
 | 
			
		||||
      if (OB_TMP_FAIL(MTL(ObScheduleSuspectInfoMgr *)->delete_info(hash_value))) { \
 | 
			
		||||
        if (OB_HASH_NOT_EXIST != ret) {                                                                \
 | 
			
		||||
          STORAGE_LOG(WARN, "failed to add suspect info", K(tmp_ret), K(dag_hash), K(tenant_id));         \
 | 
			
		||||
        if (OB_HASH_NOT_EXIST != tmp_ret) {                                                                \
 | 
			
		||||
          STORAGE_LOG(WARN, "failed to del suspect info", K(tmp_ret), K(dag_hash), K(tenant_id));         \
 | 
			
		||||
        } else {                                                                                      \
 | 
			
		||||
          tmp_ret = OB_SUCCESS;                                                                           \
 | 
			
		||||
        }                                                                                            \
 | 
			
		||||
      } else {                                                                                      \
 | 
			
		||||
        STORAGE_LOG(DEBUG, "success to add suspect info", K(tmp_ret), K(dag_hash), K(tenant_id));       \
 | 
			
		||||
        STORAGE_LOG(DEBUG, "success to del suspect info", K(tmp_ret), K(dag_hash), K(tenant_id));       \
 | 
			
		||||
      }                                                                                       \
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
		Reference in New Issue
	
	Block a user