From 8e93e53fb84951de68457cf96dc1c86e75749252 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Tue, 12 Jan 2021 11:00:28 +0000 Subject: add rampUpSleep before processing mapreduce results --- internal/clients/maprclient.go | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'internal/clients') diff --git a/internal/clients/maprclient.go b/internal/clients/maprclient.go index 1c0c2cc..1522537 100644 --- a/internal/clients/maprclient.go +++ b/internal/clients/maprclient.go @@ -131,6 +131,10 @@ func (c MaprClient) makeCommands() (commands []string) { } func (c *MaprClient) periodicReportResults(ctx context.Context) { + rampUpSleep := c.query.Interval / 2 + logger.Debug("Ramp up sleeping before processing mapreduce results", rampUpSleep) + time.Sleep(rampUpSleep) + for { select { case <-time.After(c.query.Interval): -- cgit v1.2.3