Skip to content

Commit 472c434

Browse files
gaobinlongtqranjan
authored andcommitted
Resolve compile error (opensearch-project#18005)
Signed-off-by: Binlong Gao <gbinlong@amazon.com> Signed-off-by: Tanishq Ranjan <tqranjan@amazon.com>
1 parent a24232a commit 472c434

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/src/main/java/org/opensearch/indices/pollingingest/DefaultStreamPoller.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ protected void startPoll() {
206206
results = consumer.readNext(initialBatchStartPointer, true, maxPollSize, pollTimeout);
207207
includeBatchStartPointer = false;
208208
} else if (failedShardPointer != null) {
209-
results = consumer.readNext(failedShardPointer, true, MAX_POLL_SIZE, POLL_TIMEOUT);
209+
results = consumer.readNext(failedShardPointer, true, maxPollSize, pollTimeout);
210210
failedShardPointer = null;
211211
} else {
212212
results = consumer.readNext(maxPollSize, pollTimeout);

0 commit comments

Comments
 (0)