wader/fq
1
1
Fork 0
mirror of https://github.com/wader/fq.git synced 2024-11-24 03:05:22 +03:00
Code Issues Projects Releases Wiki Activity

avro_ocf: Fix panic on missing meta schema

Browse Source
This commit is contained in:
Mattias Wadman 2022-07-23 22:16:56 +02:00
parent 8b5cc89641
commit 5d67df47e2
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
format/avro/avro_ocf.go
View File

@ -70,7 +70,12 @@ func decodeHeader(d *decode.D) HeaderData {
d.Fatalf("header.meta is not a map")
}
headerData.Schema, err = schema.FromSchemaString(meta["avro.schema"].(string))
metaSchema, ok := meta["avro.schema"].(string)
if !ok {
d.Fatalf("missing meta avro.schema")
}
headerData.Schema, err = schema.FromSchemaString(metaSchema)
if err != nil {
d.Fatalf("failed to parse schema: %v", err)
}