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
+		}
 	}
 }