Skip to content

Commit 1cdc825

Browse files
committed
improved exception message when backpressure does not leave room for the producer to call MoveNext()
1 parent d4bb03a commit 1cdc825

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Nest/Document/Multiple/Reindex/ReindexObservable.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ private ProducerConsumerBackPressure CreateBackPressure(IBulkAllRequest<IHitMeta
133133

134134
var funnelExact = producerBandwidth == bulkSize;
135135
if (funnelExact)
136-
throw new Exception("The back pressure settings are too conservative it provides enough documents for a single bulk but not enough room to advance "
136+
throw new Exception("The back pressure settings are too conservative. They provide enough documents for a single bulk but not enough room to advance "
137137
+ $"searchSize:{searchSize} * maxConcurrency:{maxConcurrency} * backPressureFactor:{backPressureFactor} = {producerBandwidth}"
138138
+ $" which is exactly the bulkSize:{bulkSize}. Increase the BulkAll max concurrency or the backPressureFactor"
139139
);
@@ -242,4 +242,4 @@ public void Dispose()
242242
this._compositeCancelTokenSource?.Cancel();
243243
}
244244
}
245-
}
245+
}

0 commit comments

Comments
 (0)