Skip to content

Commit e61b6ab

Browse files
authored
Resolve compile error (#18005)
Signed-off-by: Binlong Gao <gbinlong@amazon.com>
1 parent cf6ed3c commit e61b6ab

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)