Merge pull request #3522 from dim/fix-cq-timeout-bug

Consume CQ results on request timeouts

services/continuous_querier/service.go

@@ -288,6 +288,12 @@ func (s *Service) runContinuousQueryAndWriteResult(cq *ContinuousQuery) error {
 		return err
 	}
 
+	// Drain results
+	defer func() {
+		for _ = range ch {
+		}
+	}()
+
 	// Read all rows from the result channel.
 	for result := range ch {
 		if result.Err != nil {