error if can't retry on more hosts

apache · Oct 11, 2018 · ffb9c15 · ffb9c15
1 parent aa46e85
commit ffb9c15
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/query_executor.go b/query_executor.go
@@ -152,6 +152,9 @@ func (q *queryExecutor) run(qry ExecutableQuery, specWG *sync.WaitGroup, results
 			case RetryNextHost:
 				// retry on the next host
 				selectedHost = hostIter()
+				if selectedHost == nil {
+					results <- queryResponse{iter: iter}
+				}
 				continue
 			default:
 				// Undefined? Return nil and error, this will panic in the requester