Fix bug where group by times that are less than duration of a shard but would require a split would not be calculated properly.

pull/269/head
Paul Dix 2014-02-18 13:49:32 -05:00
parent 31bfc03728
commit 8947bb7673
1 changed files with 1 additions and 1 deletions

View File

@ -256,7 +256,7 @@ func (self *ShardData) ShouldAggregateLocally(querySpec *parser.QuerySpec) bool
if groupByInterval == nil {
return false
}
if groupByInterval.Seconds() <= self.shardDuration.Seconds() {
if self.shardDuration%*groupByInterval == 0 {
return true
}
return false