From d11ce27f330a29957963c4e9572ad56532844947 Mon Sep 17 00:00:00 2001 From: Bill Rich Date: Tue, 30 Aug 2022 10:24:52 -0700 Subject: [PATCH] Use correct reader in filesystem source (#756) --- pkg/sources/filesystem/filesystem.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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,