From f4f20f17f21a42b6be018454464a7b609c472034 Mon Sep 17 00:00:00 2001 From: Edd Robinson <me@edd.io> Date: Mon, 14 Mar 2016 23:47:55 +0000 Subject: [PATCH] Wire up DROP SHARD to executor --- cluster/query_executor.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/cluster/query_executor.go b/cluster/query_executor.go index 4f2fa85214..881ef7aca0 100644 --- a/cluster/query_executor.go +++ b/cluster/query_executor.go @@ -145,6 +145,8 @@ func (e *QueryExecutor) executeQuery(query *influxql.Query, database string, chu err = e.executeDropRetentionPolicyStatement(stmt) case *influxql.DropServerStatement: err = influxql.ErrInvalidQuery + case *influxql.DropShardStatement: + err = e.executeDropShardStatement(stmt) case *influxql.DropSubscriptionStatement: err = e.executeDropSubscriptionStatement(stmt) case *influxql.DropUserStatement: