Merge pull request #4730 from neethuhaneesha/master

Adding TraceEvent when a worker is removed from cluster controller.
This commit is contained in:
Vishesh Yadav 2021-05-06 22:46:32 -07:00 committed by GitHub
commit 5ca3b671d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -3092,6 +3092,10 @@ ACTOR Future<Void> workerAvailabilityWatch(WorkerInterface worker,
if (worker.locality.processId() == cluster->masterProcessId) {
cluster->masterProcessId = Optional<Key>();
}
TraceEvent("ClusterControllerWorkerFailed", cluster->id)
.detail("ProcessId", worker.locality.processId())
.detail("ProcessClass", failedWorkerInfo.details.processClass.toString())
.detail("Address", worker.address());
cluster->removedDBInfoEndpoints.insert(worker.updateServerDBInfo.getEndpoint());
cluster->id_worker.erase(worker.locality.processId());
cluster->updateWorkerList.set(worker.locality.processId(), Optional<ProcessData>());