diff options
| -rw-r--r-- | dataset/parquet.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/dataset/parquet.go b/dataset/parquet.go index 6710260..4b3d858 100644 --- a/dataset/parquet.go +++ b/dataset/parquet.go @@ -161,6 +161,12 @@ func (p *ParquetReader) read(name string) iter.Seq[string] { } } } + + if err := recordReader.Err(); err != nil { + p.err = err + + return + } } } |