diff --git a/pkg/sources/filesystem/filesystem.go b/pkg/sources/filesystem/filesystem.go
index c2030b030..e0863b706 100644
--- a/pkg/sources/filesystem/filesystem.go
+++ b/pkg/sources/filesystem/filesystem.go
@@ -140,7 +140,7 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk) err
 			}
 			reReader.Stop()
 
-			for chunkData := range common.ChunkReader(inputFile) {
+			for chunkData := range common.ChunkReader(reReader) {
 				chunksChan <- &sources.Chunk{
 					SourceType: s.Type(),
 					SourceName: s.name,