fixed a few slow tasks

This commit is contained in:
Evan Tschannen 2018-07-12 14:06:59 -07:00
parent d12dac60ec
commit 392c73affb
3 changed files with 2 additions and 5 deletions

View File

@ -1275,6 +1275,7 @@ ACTOR Future<Void> teamTracker( DDTeamCollection *self, Reference<IDataDistribut
state bool lastZeroHealthy = self->zeroHealthyTeams->get();
Void _ = wait( yield() );
TraceEvent("TeamTrackerStarting", self->masterId).detail("Reason", "Initial wait complete (sc)").detail("Team", team->getDesc());
try {

View File

@ -555,10 +555,6 @@ ACTOR Future<Void> shardTracker(
Void _ = wait( delay(0, TaskDataDistribution) );
}
} catch (Error& e) {
TraceEvent(SevWarn, "ShardTrackerError", self->masterId)
.detail("TrackerID", trackerID)
.detail("Keys", printable(keys))
.error(e);
if (e.code() != error_code_actor_cancelled)
self->output.sendError(e); // Propagate failure to dataDistributionTracker
throw e;

View File

@ -62,7 +62,7 @@ ServerKnobs::ServerKnobs(bool randomize, ClientKnobs* clientKnobs) {
init( PEEK_TRACKER_EXPIRATION_TIME, 600 ); if( randomize && BUGGIFY ) PEEK_TRACKER_EXPIRATION_TIME = g_random->coinflip() ? 0.1 : 60;
init( PARALLEL_GET_MORE_REQUESTS, 32 ); if( randomize && BUGGIFY ) PARALLEL_GET_MORE_REQUESTS = 2;
init( MAX_QUEUE_COMMIT_BYTES, 15e6 ); if( randomize && BUGGIFY ) MAX_QUEUE_COMMIT_BYTES = 5000;
init( VERSIONS_PER_BATCH, VERSIONS_PER_SECOND ); if( randomize && BUGGIFY ) VERSIONS_PER_BATCH = std::max<int64_t>(1,VERSIONS_PER_SECOND/1000);
init( VERSIONS_PER_BATCH, VERSIONS_PER_SECOND/10 ); if( randomize && BUGGIFY ) VERSIONS_PER_BATCH = std::max<int64_t>(1,VERSIONS_PER_SECOND/1000);
// Data distribution queue
init( HEALTH_POLL_TIME, 1.0 );