* Return last error if can't retry on more hosts
@@ -152,6 +152,10 @@ 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}
+ return
+ }
continue
default:
// Undefined? Return nil and error, this will panic in the requester