Skip to content

Commit

Permalink
Handle distributed queries when shards != data nodes
Browse files Browse the repository at this point in the history
Fixes #2272

There was previously a explict panic put in the query engine to prevent
queries where the number of shards was not equal to the number of data nodes
in the cluster.  This was waiting for the distributed queries branch to land
but was not removed when that landed.
  • Loading branch information
jwilder committed Apr 19, 2015
1 parent 3332f09 commit d68ce45
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions tx.go
Original file line number Diff line number Diff line change
Expand Up @@ -142,10 +142,6 @@ func (tx *tx) CreateMapReduceJobs(stmt *influxql.SelectStatement, tagKeys []stri

// create mappers for each shard we need to hit
for _, sg := range shardGroups {
if len(sg.Shards) != 1 { // we'll only have more than 1 shard in a group when RF < # servers in cluster
// TODO: implement distributed queries.
panic("distributed queries not implemented yet and there are too many shards in this group")
}

shard := sg.Shards[0]

Expand Down

0 comments on commit d68ce45

Please sign in to comment.