Skip to content

Commit d71066c

Browse files
gaobinlongHarsh Kothari
authored and
Harsh Kothari
committed
Resolve compile error (opensearch-project#18005)
Signed-off-by: Binlong Gao <gbinlong@amazon.com> Signed-off-by: Harsh Kothari <techarsh@amazon.com>
1 parent 902c1a5 commit d71066c

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)