Added worker network address and process class details to trace log.

This commit is contained in:
Neethu Haneesha Bingi 2021-04-30 01:42:54 -07:00
parent 97cd53d649
commit 7a6d7cae96
1 changed files with 4 additions and 1 deletions

View File

@ -3095,7 +3095,10 @@ ACTOR Future<Void> workerAvailabilityWatch(WorkerInterface worker,
cluster->removedDBInfoEndpoints.insert(worker.updateServerDBInfo.getEndpoint());
cluster->id_worker.erase(worker.locality.processId());
cluster->updateWorkerList.set(worker.locality.processId(), Optional<ProcessData>());
TraceEvent("ClusterFailedWorker", cluster->id).detail("WorkerProcessId", worker.locality.processId());
TraceEvent("ClusterControllerWorkerFailed", cluster->id)
.detail("WorkerProcessId", worker.locality.processId())
.detail("WorkerProcessClass", failedWorkerInfo.details.processClass.toString())
.detail("WorkerAddress", worker.address());
return Void();
}
}