Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

change printf to debug

pull/293/merge
John Shahid 2014-03-16 15:26:29 -04:00
parent c056cf5f47
commit eb292f7414
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/cluster/shard.go
View File

@ -219,7 +219,7 @@ func (self *ShardData) Query(querySpec *parser.QuerySpec, response chan *p.Respo
processor = engine.NewPassthroughEngine(response, maxDeleteResults)
} else {
if self.ShouldAggregateLocally(querySpec) {
fmt.Printf("creating a query engine\n")
log.Debug("creating a query engine\n")
processor, err = engine.NewQueryEngine(querySpec.SelectQuery(), response)
if err != nil {
response <- &p.Response{Type: &endStreamResponse, ErrorMessage: p.String(err.Error())}
@ -229,6 +229,7 @@ func (self *ShardData) Query(querySpec *parser.QuerySpec, response chan *p.Respo
processor.SetShardInfo(int(self.Id()), self.IsLocal)
} else {
maxPointsToBufferBeforeSending := 1000
log.Debug("creating a passthrough engine\n")
processor = engine.NewPassthroughEngine(response, maxPointsToBufferBeforeSending)
}
}