Skip to content
This repository has been archived by the owner on Dec 1, 2018. It is now read-only.

Commit

Permalink
Browse files Browse the repository at this point in the history
Merge pull request #1236 from mwringe/verbose_logs
Reduce when some of our messages get logged.
  • Loading branch information
mwielgus committed Aug 5, 2016
2 parents 137a8d5 + eb506cd commit c192564
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion metrics/processors/node_aggregator.go
Expand Up @@ -41,7 +41,7 @@ func (this *NodeAggregator) Process(batch *core.DataBatch) (*core.DataBatch, err
nodeKey := core.NodeKey(nodeName)
node, found := batch.MetricSets[nodeKey]
if !found {
glog.Warningf("Failed to find node: %s", nodeKey)
glog.V(1).Info("No metric for node %s, cannot perform node level aggregation.")
} else if err := aggregate(metricSet, node, this.MetricsToAggregate); err != nil {
return nil, err
}
Expand Down
4 changes: 2 additions & 2 deletions metrics/sources/manager.go
Expand Up @@ -76,7 +76,7 @@ func (this *sourceManager) Name() string {
}

func (this *sourceManager) ScrapeMetrics(start, end time.Time) *DataBatch {
glog.Infof("Scraping metrics start: %s, end: %s", start, end)
glog.V(1).Infof("Scraping metrics start: %s, end: %s", start, end)
sources := this.metricsSourceProvider.GetMetricsSources()

responseChannel := make(chan *DataBatch)
Expand Down Expand Up @@ -149,7 +149,7 @@ responseloop:
}
}

glog.Infof("ScrapeMetrics: time: %s size: %d", time.Since(startTime), len(response.MetricSets))
glog.V(1).Infof("ScrapeMetrics: time: %s size: %d", time.Since(startTime), len(response.MetricSets))
for i, value := range latencies {
glog.V(1).Infof(" scrape bucket %d: %d", i, value)
}
Expand Down

0 comments on commit c192564

Please sign in to comment.