Skip to content

Commit

Permalink
Fix broken test.
Browse files Browse the repository at this point in the history
Signed-off-by: Marc Handalian <handalm@amazon.com>
  • Loading branch information
mch2 committed Mar 15, 2023
1 parent 88663e7 commit eb32b8b
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -53,12 +53,11 @@ public class NRTReplicationReaderManager extends OpenSearchReaderManager {
OpenSearchDirectoryReader reader,
Consumer<Collection<String>> onNewReader,
Consumer<Collection<String>> onReaderClosed
) throws IOException {
) {
super(reader);
currentInfos = unwrapStandardReader(reader).getSegmentInfos();
this.onReaderClosed = onReaderClosed;
this.onNewReader = onNewReader;
onNewReader.accept(currentInfos.files(true));
}

@Override
Expand Down

0 comments on commit eb32b8b

Please sign in to comment.