summaryrefslogtreecommitdiff
path: root/internal/clients/maprclient.go
diff options
context:
space:
mode:
authorPaul Buetow <git@mx.buetow.org>2020-12-26 14:28:31 +0000
committerPaul Buetow <git@mx.buetow.org>2020-12-26 14:28:31 +0000
commitf9415259bc5d74a89801be75587da87dd37518af (patch)
tree7bfb13bf19e3f1fe8d8c4e5d54d1331ebaad55f5 /internal/clients/maprclient.go
parentb05ae938aa6ada831d19de076861e246a03a9d7d (diff)
initial quiet switch
Diffstat (limited to 'internal/clients/maprclient.go')
-rw-r--r--internal/clients/maprclient.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/clients/maprclient.go b/internal/clients/maprclient.go
index 9beea13..1c0c2cc 100644
--- a/internal/clients/maprclient.go
+++ b/internal/clients/maprclient.go
@@ -99,7 +99,7 @@ func (c *MaprClient) Start(ctx context.Context, statsCh <-chan string) (status i
status = c.baseClient.Start(ctx, statsCh)
if c.cumulative {
- logger.Info("Received final mapreduce result")
+ logger.Debug("Received final mapreduce result")
c.reportResults()
}
@@ -134,7 +134,7 @@ func (c *MaprClient) periodicReportResults(ctx context.Context) {
for {
select {
case <-time.After(c.query.Interval):
- logger.Info("Gathering interim mapreduce result")
+ logger.Debug("Gathering interim mapreduce result")
c.reportResults()
case <-ctx.Done():
return
@@ -166,7 +166,7 @@ func (c *MaprClient) printResults() {
}
if numLines == 0 {
- logger.Info("Empty result set this time...")
+ logger.Warn("Empty result set this time...")
return
}