diff options
| author | Jonas Knobloch <jonas.knobloch@t-online.de> | 2026-04-21 19:45:26 +0200 |
|---|---|---|
| committer | Jonas Knobloch <jonas.knobloch@t-online.de> | 2026-04-22 12:53:39 +0200 |
| commit | 37a72f340669cdd985e992d8e37916c6575414d6 (patch) | |
| tree | 3348091ed34a3790f1ea7fce019084c7d5a9ff2d | |
| parent | d2cf0b9bcf8ad3ab621b8ce7830fa40e203ec4d6 (diff) | |
Propagate record reader error
| -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 + } } } |