From 762a1c69d5c98d9fa136b61a43f414fd259553c8 Mon Sep 17 00:00:00 2001
From: Dimitrij Denissenko <dimitrij.denissenko@blacksquaremedia.com>
Date: Thu, 30 Jul 2015 16:59:47 +0100
Subject: [PATCH] Consume CQ results on request timeouts

---
 services/continuous_querier/service.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/services/continuous_querier/service.go b/services/continuous_querier/service.go
index 5f296277fa..8ce1c2b093 100644
--- a/services/continuous_querier/service.go
+++ b/services/continuous_querier/service.go
@@ -286,6 +286,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 {