diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2021-10-21 21:02:58 +0300 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2021-10-21 21:02:58 +0300 |
| commit | a1ee5e7700f22c5a9b0a6654291eb46bdf4e6272 (patch) | |
| tree | a815db368aa1f644988eed5d1fb092a3da164cb2 /internal | |
| parent | bb1cfe59a98f656e011db97f2bea789ec5cded03 (diff) | |
backport mapreduce reporter rampup from master
Diffstat (limited to 'internal')
| -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 074494c..246946f 100644 --- a/internal/clients/maprclient.go +++ b/internal/clients/maprclient.go @@ -137,6 +137,10 @@ func (c MaprClient) makeCommands() (commands []string) { } func (c *MaprClient) periodicReportResults(ctx context.Context) { + rampUpSleep := c.query.Interval / 2 + dlog.Client.Debug("Ramp up sleeping before processing mapreduce results", rampUpSleep) + time.Sleep(rampUpSleep) + for { select { case <-time.After(c.query.Interval): |