Use correct reader in filesystem source (#756)

This commit is contained in:
Bill Rich 2022-08-30 10:24:52 -07:00 committed by GitHub
parent 37c4eea66a
commit d11ce27f33
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -140,7 +140,7 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk) err
} }
reReader.Stop() reReader.Stop()
for chunkData := range common.ChunkReader(inputFile) { for chunkData := range common.ChunkReader(reReader) {
chunksChan <- &sources.Chunk{ chunksChan <- &sources.Chunk{
SourceType: s.Type(), SourceType: s.Type(),
SourceName: s.name, SourceName: s.name,