diff options
Diffstat (limited to 'internal/mapr/client')
| -rw-r--r-- | internal/mapr/client/aggregate.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/mapr/client/aggregate.go b/internal/mapr/client/aggregate.go index 02a6a5a..1704d43 100644 --- a/internal/mapr/client/aggregate.go +++ b/internal/mapr/client/aggregate.go @@ -54,7 +54,7 @@ func (a *Aggregate) Aggregate(message string) error { for _, sc := range a.query.Select { if val, ok := fields[sc.FieldStorage]; ok { if err := set.Aggregate(sc.FieldStorage, sc.Operation, val, true); err != nil { - dlog.Common.Error(err) + dlog.Client.Error(err) continue } addedSamples = true |
