diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2021-02-04 17:15:09 +0000 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2021-02-04 17:15:09 +0000 |
| commit | 4bc21c8b3b332bf57760090849e91d12aa704973 (patch) | |
| tree | 872e24270f6a348446b2f2c194b4be4c839b010d /internal/clients | |
| parent | 6408c5cdd3e5d79ae42201b43f133ad75c281aad (diff) | |
| parent | 8e93e53fb84951de68457cf96dc1c86e75749252 (diff) | |
merge developv3.2.1
Diffstat (limited to 'internal/clients')
| -rw-r--r-- | internal/clients/maprclient.go | 4 |
1 files changed, 4 insertions, 0 deletions
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): |