diff --git a/component/clusterd/pkg/application/faultmanager/jobprocess/relationfault/relation_fault_processor.go b/component/clusterd/pkg/application/faultmanager/jobprocess/relationfault/relation_fault_processor.go index fb47d7dd4b3c8b1e6262dfebab6483d0c830f722..e6df809d7fb42ff92a8a0eef3b54126d449bddea 100644 --- a/component/clusterd/pkg/application/faultmanager/jobprocess/relationfault/relation_fault_processor.go +++ b/component/clusterd/pkg/application/faultmanager/jobprocess/relationfault/relation_fault_processor.go @@ -379,6 +379,7 @@ func (fJob *FaultJob) addFaultInfoByCodeType(faultInfo *constant.FaultInfo) { } fJob.TriggerFault = append(fJob.TriggerFault, *faultInfo) } + } func isAssociateFault(faultCode string) bool { diff --git a/component/taskd/taskd/go/backend_api.go b/component/taskd/taskd/go/backend_api.go index abb9475c2f47ada53be15a2c8f861cd34c8588c2..f25a6f2ef1f7c4395ff6b6a40465fa2ae7f91b41 100644 --- a/component/taskd/taskd/go/backend_api.go +++ b/component/taskd/taskd/go/backend_api.go @@ -66,6 +66,7 @@ func InitWorker(globalRank, nodeRank, upperLimitOfDiskInMb int) C.int { hwlog.RunLog.Errorf("Received signal: %v, exiting...", sig) cancel() }() + err := utils.InitHwLog(fmt.Sprintf(constant.WorkerLogPathPattern, strconv.Itoa(globalRank)), ctx) if err != nil { fmt.Println(err)