diff options
Diffstat (limited to 'internal/clients/maprclient.go')
| -rw-r--r-- | internal/clients/maprclient.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/clients/maprclient.go b/internal/clients/maprclient.go index d154c9d..581db44 100644 --- a/internal/clients/maprclient.go +++ b/internal/clients/maprclient.go @@ -94,10 +94,10 @@ func NewMaprClient(args Args, queryStr string, maprClientMode MaprClientMode) (* } // Start starts the mapreduce client. -func (c *MaprClient) Start(ctx context.Context) (status int) { +func (c *MaprClient) Start(ctx context.Context, statsCh <-chan struct{}) (status int) { go c.periodicReportResults(ctx) - status = c.baseClient.Start(ctx) + status = c.baseClient.Start(ctx, statsCh) if c.cumulative { logger.Info("Received final mapreduce result") c.reportResults() |