Fix some log statements

src/cluster/cluster_configuration.go

@@ -952,7 +952,7 @@ func (self *ClusterConfiguration) AddShards(shards []*NewShardData) ([]*ShardDat
 
 		createdShards = append(createdShards, shard)
 
-		log.Info("%s: %d - start: %s (%d). end: %s (%d). isLocal: %d. servers: %s",
+		log.Info("%s: %d - start: %s (%d). end: %s (%d). isLocal: %v. servers: %v",
 			message, shard.Id(),
 			shard.StartTime().Format("Mon Jan 2 15:04:05 -0700 MST 2006"), shard.StartTime().Unix(),
 			shard.EndTime().Format("Mon Jan 2 15:04:05 -0700 MST 2006"), shard.EndTime().Unix(),

src/cluster/shard.go

@@ -401,7 +401,7 @@ func (self *ShardData) QueryResponseBufferSize(querySpec *parser.QuerySpec, batc
 		// each response can have many points, so having a buffer of the ticks * 100 should be safe, but we'll see.
 		tickCount = tickCount * 100
 	}
-	log.Debug("BUFFER SIZE: ", tickCount)
+	log.Debug("BUFFER SIZE: %d", tickCount)
 	return tickCount
 }
 

src/coordinator/coordinator.go

@@ -68,7 +68,7 @@ func NewCoordinatorImpl(config *configuration.Configuration, raftServer ClusterC
 func (self *CoordinatorImpl) RunQuery(user common.User, database string, queryString string, seriesWriter SeriesWriter) (err error) {
 	log.Info("Start Query: db: %s, u: %s, q: %s", database, user.GetName(), queryString)
 	defer func(t time.Time) {
-		log.Debug("End Query: db: %s, u: %s, q: %s, t: %f", database, user.GetName(), queryString, time.Now().Sub(t))
+		log.Debug("End Query: db: %s, u: %s, q: %s, t: %s", database, user.GetName(), queryString, time.Now().Sub(t))
 	}(time.Now())
 	// don't let a panic pass beyond RunQuery
 	defer common.RecoverFunc(database, queryString, nil)
@@ -340,7 +340,7 @@ func (self *CoordinatorImpl) readFromResponseChannels(processor cluster.QueryPro
 		for response := range responseChan {
 
 			//log.Debug("GOT RESPONSE: ", response.Type, response.Series)
-			log.Debug("GOT RESPONSE: ", response.Type)
+			log.Debug("GOT RESPONSE: %v", response.Type)
 			if *response.Type == endStreamResponse || *response.Type == accessDeniedResponse {
 				if response.ErrorMessage == nil {
 					break
@@ -402,7 +402,7 @@ func (self *CoordinatorImpl) queryShards(querySpec *parser.QuerySpec, shards []*
 		}
 		responseChan := make(chan *protocol.Response, bufferSize)
 		// We query shards for data and stream them to query processor
-		log.Debug("QUERYING: shard: ", i, shard.String())
+		log.Debug("QUERYING: shard: %d %v", i, shard.String())
 		go shard.Query(querySpec, responseChan)
 		responseChannels <- responseChan
 	}
@@ -430,7 +430,7 @@ func (self *CoordinatorImpl) runQuerySpec(querySpec *parser.QuerySpec, seriesWri
 		log.Debug("Querying shards sequentially")
 		shardConcurrentLimit = 1
 	}
-	log.Debug("Shard concurrent limit: ", shardConcurrentLimit)
+	log.Debug("Shard concurrent limit: %d", shardConcurrentLimit)
 
 	errors := make(chan error, shardConcurrentLimit)
 	for i := 0; i < shardConcurrentLimit; i++ {

src/coordinator/raft_server.go

@@ -710,7 +710,7 @@ func (self *RaftServer) CreateShards(shards []*cluster.NewShardData) ([]*cluster
 	if err != nil {
 		return nil, err
 	}
-	log.Debug("NEW SHARDS: ", newShards)
+	log.Debug("NEW SHARDS: %v", newShards)
 	return self.clusterConfig.MarshalNewShardArrayToShards(newShards)
 }
 

src/datastore/leveldb_shard.go

@@ -338,7 +338,7 @@ func (self *LevelDbShard) executeQueryForSeries(querySpec *parser.QuerySpec, ser
 		}
 	}
 
-	log.Debug("Finished running query %s")
+	log.Debug("Finished running query %s", query.GetQueryString())
 	return nil
 }
 

src/parser/group_by.go

@@ -25,7 +25,7 @@ func (self GroupByClause) GetGroupByTime() (*time.Duration, error) {
 			}
 
 			if groupBy.Elems[0].Type != ValueDuration {
-				log.Debug("Get a time function without a duration argument %s", groupBy.Elems[0].Type)
+				log.Debug("Get a time function without a duration argument %v", groupBy.Elems[0].Type)
 			}
 			arg := groupBy.Elems[0].Name
 			durationInt, err := common.ParseTimeDuration(arg)