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: