Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

error if can't retry on more hosts #1213

Merged
merged 2 commits into from
Oct 11, 2018

Conversation

beltran
Copy link
Contributor

@beltran beltran commented Oct 11, 2018

This is breaking tests in master. Can you review @alourie ?

@beltran beltran changed the title error in can't retry on more hosts error if can't retry on more hosts Oct 11, 2018
@beltran beltran force-pushed the error_if_no_more_hosts branch from 1cd1e2f to ffb9c15 Compare October 11, 2018 00:47
@@ -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}
}
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

right, I thought it's covered but the main loop....so to avoid confusion, let's return after this. Alternatively, we can move the channel loading to after the loop, and check if the iter pointer is not nil, then push it to the results channel. I actually have no preference here on one way or the other.

@alourie alourie merged commit 2d1883b into apache:master Oct 11, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants