-
Notifications
You must be signed in to change notification settings - Fork 1.2k
Throw an exception when Reindex() produces just enough documents for … #2781
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
Conversation
russcam
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM - one very minor nitpick 😄
|
|
||
| var funnelExact = producerBandwidth == bulkSize; | ||
| if (funnelExact) | ||
| throw new Exception("The back pressure settings are too conservative it provides enough documents for a single bulk but not enough room to advance " |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
minor pedantic punctuation nitpick:
The back pressure settings are too conservative. They provide enough documents for a single bulk but not enough room to advance ...
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍 added
2b98d44 to
292abd5
Compare
…a single bulk but leaves no slots to call MoveNext() which would free up an awaiting task. fixes #2771
…the producer to call MoveNext()
292abd5 to
1cdc825
Compare
|
Only needed to be backported to |
elastic#2781) * Throw an exception when Reindex() produces just enough documents for a single bulk but leaves no slots to call MoveNext() which would free up an awaiting task. fixes elastic#2771 * improved exception message when backpressure does not leave room for the producer to call MoveNext()
…a single bulk but leaves no slots to call MoveNext() which would free up an awaiting task. fixes #2771