From eb292f741445758fc1cb6a7d56b5ed80ac14c5f2 Mon Sep 17 00:00:00 2001
From: John Shahid <jvshahid@gmail.com>
Date: Sun, 16 Mar 2014 15:26:29 -0400
Subject: [PATCH] change printf to debug

---
 src/cluster/shard.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/cluster/shard.go b/src/cluster/shard.go
index fd476a30fb..55d58348e0 100644
--- a/src/cluster/shard.go
+++ b/src/cluster/shard.go
@@ -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)
 			}
 		}