Skip to content

Commit e53f9c5

Browse files
fix file-based ingestion
Signed-off-by: Varun Bharadwaj <varunbharadwaj1995@gmail.com>
1 parent 0c89456 commit e53f9c5

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

plugins/ingestion-fs/src/main/java/org/opensearch/plugin/ingestion/fs/FilePartitionConsumer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,7 @@ private synchronized List<ReadResult<FileOffset, FileMessage>> readFromFile(long
9090
}
9191

9292
while (currentLineInReader < startLine && reader.readLine() != null) {
93+
lastReadLine = currentLineInReader;
9394
currentLineInReader++;
9495
}
9596

0 commit comments

Comments
 (0)