diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2021-01-11 17:29:26 +0000 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2021-01-11 17:29:26 +0000 |
| commit | 4e66a087c10cdd49c352416567436d8c2ef2a656 (patch) | |
| tree | ff6b93eb2250e2b1fbea1a97f3bcf3f024c45cef | |
| parent | 8c5d1b1c7bcf80ada56398422c82c9cb18ed0442 (diff) | |
also respect 'limit' when writing mapreduce result to outfile.
| -rw-r--r-- | internal/mapr/groupset.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/mapr/groupset.go b/internal/mapr/groupset.go index 70ad28b..50155f8 100644 --- a/internal/mapr/groupset.go +++ b/internal/mapr/groupset.go @@ -68,7 +68,7 @@ func (g *GroupSet) WriteResult(query *Query) error { } // -1: Don't limit the result, include all data sets - result, count, err := g.limitedResult(query, -1, "", ",", true) + result, count, err := g.limitedResult(query, query.Limit, "", ",", true) if err != nil { return err } |