Added a duration to regular relocateShard trace events
This commit is contained in:
parent
297b65236f
commit
d30d4cb955
|
@ -1068,7 +1068,7 @@ ACTOR Future<Void> dataDistributionRelocator( DDQueueData *self, RelocateData rd
|
|||
|
||||
// onFinished.send( rs );
|
||||
if( !error.code() ) {
|
||||
TraceEvent(relocateShardInterval.end(), distributorId).detail("Result","Success");
|
||||
TraceEvent(relocateShardInterval.end(), distributorId).detail("Duration", now() - startTime).detail("Result","Success");
|
||||
if(now() - startTime > 600) {
|
||||
TraceEvent(SevWarnAlways, "RelocateShardTooLong").detail("Duration", now() - startTime).detail("Dest", describe(destIds));
|
||||
}
|
||||
|
@ -1095,7 +1095,7 @@ ACTOR Future<Void> dataDistributionRelocator( DDQueueData *self, RelocateData rd
|
|||
}
|
||||
}
|
||||
} catch (Error& e) {
|
||||
TraceEvent(relocateShardInterval.end(), distributorId).error(e, true);
|
||||
TraceEvent(relocateShardInterval.end(), distributorId).error(e, true).detail("Duration", now() - startTime);
|
||||
if(now() - startTime > 600) {
|
||||
TraceEvent(SevWarnAlways, "RelocateShardTooLong").error(e, true).detail("Duration", now() - startTime).detail("Dest", describe(destIds));
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue